Java class to get Observable from TextView/EditText or class extend TextView

RxUtils.java

public static Observable<String> getTextWatcherObservable(TextView textView){

        final PublishSubject<String> subject = PublishSubject.create();

        textView.addTextChangedListener(new TextWatcher() {
            @Override
            public void beforeTextChanged(CharSequence s, int start, int count, int after) {

            }

            @Override
            public void onTextChanged(CharSequence s, int start, int before, int count) {

            }

            @Override
            public void afterTextChanged(Editable s) {
                subject.onNext(s.toString());
            }
        });

        return subject;
    }

    public static Observable<Integer> itemSelectionObservable(Spinner spinner){
        final PublishSubject<Integer> subject = PublishSubject.create();
        spinner.setOnItemSelectedListener(new AdapterView.OnItemSelectedListener() {
            @Override
            public void onItemSelected(AdapterView<?> parent, View view, int position, long id) {
                subject.onNext(position);
            }

            @Override
            public void onNothingSelected(AdapterView<?> parent) {
                subject.onNext(0);
            }
        });
        return subject;
    }