@BindingAdapter("app:rxText")
public static void rxText(TextInputEditText editText, final BehaviorSubject<String> subject) {

    // Initial value
    editText.setText(subject.getValue());

    // Text changes
    editText.addTextChangedListener(new TextWatcher() {
        @Override
        public void beforeTextChanged(CharSequence charSequence, int start, int count, int after) {
        }

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

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