Как реализовать периодическую обработку ввода пользователя?

Ответ 1

Что-то вроде этого должно работать (на самом деле не пыталось это сделать)

 Single<String> firstTypeOnlyStream = RxTextView.textChanges(mEditText)
            .skipInitialValue()
            .map(CharSequence::toString)
            .firstOrError();

    Observable<CharSequence> restartTypingStream = RxTextView.textChanges(mEditText)
            .filter(charSequence -> charSequence.length() == 0);

    Single<String> latestTextStream = RxTextView.textChanges(mEditText)
            .map(CharSequence::toString)
            .firstOrError();

    Observable<TextViewEditorActionEvent> enterStream =
            RxTextView.editorActionEvents(mEditText, actionEvent -> actionEvent.actionId() == EditorInfo.IME_ACTION_DONE);

    firstTypeOnlyStream
            .flatMapObservable(__ ->
                    latestTextStream
                            .toObservable()
                            .doOnNext(text -> nextDelay = delayByLength(text.length()))
                            .repeatWhen(objectObservable -> objectObservable
                                    .flatMap(o -> Observable.timer(nextDelay, TimeUnit.MILLISECONDS)))
                            .distinctUntilChanged()
                            .flatMap(text -> {
                                if (text.length() > MINIMUM_TEXT_LENGTH) {
                                    return apiRequest(text);
                                } else {
                                    return Observable.empty();
                                }
                            })
            )
            .takeUntil(restartTypingStream)
            .repeat()
            .takeUntil(enterStream)
            .mergeWith(enterStream.flatMap(__ ->
                    latestTextStream.flatMapObservable(this::apiRequest)
            ))
            .subscribe(requestResult -> {
                //do your thing with each request result
            });

Идея состоит в том, чтобы сконструировать поток, основанный на выборке, а не на самих изменениях текста, основываясь на вашем требовании пробы каждого X-времени.

То, как я это сделал, заключается в том, чтобы построить один поток (firstTypeOnlyStream для первоначального запуска событий (первый пользовательский текст ввода), этот поток начнет весь поток обработки с первого ввода пользователя, затем, когда это первый триггер приходит, мы в основном образец редактировать текст периодически используя latestTextStream. latestTextStream не совсем потока с течением времени, а выборка из текущего состояния EditText используя InitialValueObservable свойства RxBinding (она просто излучает по подписке, ток текст в EditText), другими словами, это причудливый способ получить текущий текст при подписке, и это эквивалентно:
Observable.fromCallable(() → mEditText.getText().toString());
затем, для динамического таймаута/задержки, мы обновляем nextDelay на основе длины текста и используем repeatWhen с таймером, чтобы ждать желаемого времени. вместе с distinctUntilChanged, он должен дать желаемую выборку на основе длины текста. далее, мы будем уволить запрос на основе текста (если достаточно долго).

Остановить с помощью Enter - использовать takeUntil с enterStream который будет активирован при enterStream а также инициирует окончательный запрос.

Перезапуск - когда пользователь "перезапускает" ввод, т. .takeUntil(restartTypingStream) Текст пуст, .takeUntil(restartTypingStream) + repeat() останавливает поток при вводе пустой строки и перезапускает его (переписывает).

Ответ 2

Вы можете найти то, что вам нужно в as оператора. Требуется ObservableConverter который позволяет конвертировать ваш источник Observable в произвольный объект. Этот объект может быть другим Observable с произвольно сложным поведением.

public class MyConverter implements ObservableConverter<Foo, Observable<Bar>> {
    Observable<Bar> apply(Observable<Foo> upstream) {
        final PublishSubject<Bar> downstream = PublishSubject.create();
        // subscribe to upstream
        // subscriber publishes to downstream according to your rules
        return downstream;
    }
}

Затем используйте его следующим образом:

someObservableOfFoo.as(new MyConverter())... // more operators

Редактировать: Я думаю, что compose может быть более парадигматичным. Это менее мощная версия as специально для создания Observable а не для любого объекта. Использование по сути то же самое. См. Этот учебник.

Ответ 3

Ну, вы можете использовать что-то вроде этого:

RxSearch.fromSearchView(searchView)
            .debounce(300, TimeUnit.MILLISECONDS)
            .filter(item -> item.length() > 1)
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(query -> {
                adapter.setNamesList(namesAPI.searchForName(query));
                adapter.notifyDataSetChanged();
                apiCallsTextView.setText("API CALLS: " + apiCalls++);
            });    

public class RxSearch {
    public static Observable<String> fromSearchView(@NonNull final SearchView searchView) {
        final BehaviorSubject<String> subject = BehaviorSubject.create("");

        searchView.setOnQueryTextListener(new SearchView.OnQueryTextListener() {

            @Override
            public boolean onQueryTextSubmit(String query) {
                subject.onCompleted();
                return true;
            }

            @Override
            public boolean onQueryTextChange(String newText) {
                if (!newText.isEmpty()) {
                    subject.onNext(newText);
                }
                return true;
            }
        });

        return subject;
    }
}

блог referencia

Ответ 4

ваш запрос можно легко решить с помощью методов RxJava2, прежде чем я отправлю код, я добавлю шаги, которые я делаю.

1. добавьте объект PublishSubject, который будет принимать ваши входы и добавит к нему фильтр, который будет проверять, превышает ли вход два или нет.
2. добавьте метод debounce, чтобы все входные события, которые запускались до 300 мс, игнорировались, и принимался во внимание окончательный запрос, который запускается после 300 мс.
3. теперь добавьте коммутационную карту и добавьте в нее событие сетевого запроса,
4. Подпишитесь на мероприятие.

Код выглядит следующим образом:

subject = PublishSubject.create(); //add this inside your oncreate
    getCompositeDisposable().add(subject
            .doOnEach(stringNotification -> {
                if(stringNotification.getValue().length() < 3) {
                    getMvpView().hideEditLoading();
                    getMvpView().onFieldError("minimum 3 characters required");
                }
            })
            .debounce(300,
                    TimeUnit.MILLISECONDS)
            .filter(s -> s.length() >= 3)
            .switchMap(s -> getDataManager().getHosts(
                    getDataManager().getDeviceToken(),
                    s).subscribeOn(Schedulers.io()))
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(hostResponses -> {
                getMvpView().hideEditLoading();
                if (hostResponses.size() != 0) {
                    if (this.hostResponses != null)
                        this.hostResponses.clear();
                    this.hostResponses = hostResponses;
                    getMvpView().setHostView(getHosts(hostResponses));
                } else {
                    getMvpView().onFieldError("No host found");
                }

            }, throwable -> {
                getMvpView().hideEditLoading();
                if (throwable instanceof HttpException) {
                    HttpException exception = (HttpException) throwable;
                    if (exception.code() == 401) {
                        getMvpView().onError(R.string.code_expired,
                                BaseUtils.TOKEN_EXPIRY_TAG);
                    }
                }

            })
);

это будет ваш textwatcher:

searchView.addTextChangedListener(new TextWatcher() {
        @Override
        public void beforeTextChanged(CharSequence charSequence, int i, int i1, int i2) {

        }

        @Override
        public void onTextChanged(CharSequence charSequence, int i, int i1, int i2) {
            subject.onNext(charSequence.toString());
        }

        @Override
        public void afterTextChanged(Editable editable) {

        }
    });

PS Это работает для меня !!