Переопределение вызова в потоке

Question

У меня есть текст редактирования, который позволяет пользователю вводить имя пользователя и после ввода имени пользователя отправляется значение в db, чтобы проверить, существует ли имя пользователя, если нет, то дальнейшие операции разрешены иначе, отображается ошибка.

На данный момент это мой текущий код.

usernameObservable 
      .skip(2) 
      .debounce(800, TimeUnit.MILLISECONDS) 
      .subscribe(username -> { 
       Observable<Boolean> observable = apiService.isAvailable(username); 
       observable.observeOn(Schedulers.io()) 
         .observeOn(AndroidSchedulers.mainThread()) 
         .subscribe(aBoolean -> { 

         }, throwable -> { 

         }); 
      }); 

На данный момент сетевой запрос делается в конце, но это возможно сделать запрос до и один раз я получаю данные я выполнять некоторые другие операции на потоке.

Answer 1

Вы ищете flatMap оператор. Это позволяет преобразовать событие в другое наблюдаемое, которое будет направлять выбросы в исходный поток. Уведомление об ошибке также будет отправлено.

usernameObservable 
     .skip(2) 
     .debounce(800, TimeUnit.MILLISECONDS) 
     .flatMap(username -> apiService.isAvailable(username)) 
     .subscribe(isAvailableResult -> { 
      // react here 
     }, throwable -> { 
      // show an error here 
     });