RxJava 2 Disposable при уничтожении активности

как предложил @Blackbelt, существует несколько перегруженных версий subscribe() (см. документы).

• несколько, которые принимают комбинации Consumer и Action
• тот, который берет Observer

первые возвращают экземпляр Disposable, посредством чего подписка может быть прекращена; последний - нет. поэтому, если вы хотите избавиться от своего потока в onDestroy(), вам следует изменить версию subscribe(), которую вы используете.

структурно это выглядело бы примерно так:

public class Blah extends AppCompatActivity {

    private EditText passwordTxt;

    private Disposable disposable;

    @Override
    protected void onCreate(@Nullable Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);

        disposable = RxTextView.textChanges(passwordTxt)
                .debounce(400, TimeUnit.MILLISECONDS)
                .map(this::isValidPassword)
                .subscribeOn(Schedulers.io()) // Or Schedulers.newThread()
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(
                        new Consumer<Boolean>() {
                            @Override
                            public void accept(Boolean aBoolean) throws Exception {
                                // onNext
                            }
                        },
                        new Consumer<Throwable>() {
                            @Override
                            public void accept(Throwable throwable) throws Exception {
                                // onError
                            }
                        },
                        new Action() {
                            @Override
                            public void run() throws Exception {
                                // onComplete
                            }
                        },
                        new Consumer<Disposable>() {
                            @Override
                            public void accept(Disposable disposable) throws Exception {
                                // onSubscribe
                            }
                        }
                );
    }

    @Override
    protected void onDestroy() {
        super.onDestroy();

        if (disposable != null && !disposable.isDisposed()) {
            disposable.dispose();
        }
    }

    private Boolean isValidPassword(CharSequence value) {
        return value.toString().matches("^(?=.*\\d).{4,8}$");
    }

}

(хотя лямбды действительно могут сократить и, таким образом, улучшить читаемость вашего кода, я решил не использовать их, чтобы четко проиллюстрировать используемые типы).