.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
Обсуждают сегодня