input_validator.java

    ...
    
    private Disposable textWatcher;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        AppCompatEditText input = findViewById(R.id.password);
        AppCompatTextView message = findViewById(R.id.message);

        textWatcher = RxTextView.textChanges(input) // Tworzy strumien na podstawie zmian EditText
                .debounce(300, TimeUnit.MILLISECONDS) // Ogranicza emisje na odstepy co 300 milisekund
                .map(this::isPasswordValid) // Zamienia wprowadzony tekst na rezultat logiczny
                .subscribeOn(Schedulers.io()) // Powyzsze operacje wykonuje w tle na watku I/O
                .observeOn(AndroidSchedulers.mainThread()) // Rezultat jest zwracany do UI
                .subscribe( // Subskrybcja, ktora przechwytuje emisje czyli (true/false)
                        valid -> {
                            if (valid) { //Haslo zgodne ze schematem
                                message.setText("Haslo jest prawidłowe.");
                                message.setTextColor(Color.GREEN);
                            } else { //Haslo niezgodne ze schematem
                                message.setText("Haslo niezgodne z wymaganiami.");
                                message.setTextColor(Color.RED);
                            }
                        });
    }
    
    ...