.skipInitialValue()
                  
                  
                          .map(CharSequence::toString)
                  
                  
                          .map(String::trim)
                  
                  
                          .distinctUntilChanged()
                  
                  
                  
                  
                  
                  Observable<Something> o1 = queryChanges.switchmap(тут маппер);
                  
                  
                  Observable<Something> o2 = queryChanges.debounce(500, TimeUnit.MILLISECONDS).switchMap(тут другой маппер);
                  
                  
                  
                  
                  
                  Observable.merge(o1, o2).observeOn(AndroidSchedulers.mainThread())
                  
                  
                  .scan(initialValue, тут редусер)
                  
                  
                  .subscribe();o1 почему-то игнорируется. Делаю логгирование в doOnNext,  и логи выводятся только из o2
                  
                  
                
если заменить o1 на interval, то все работает, логи пишутся с обоих observable
Обсуждают сегодня