TODO for until added

This commit is contained in:
Gavriil Sitnikov 2017-01-27 14:02:17 +03:00
parent c993ebe411
commit fa4185476d
1 changed files with 1 additions and 0 deletions

View File

@ -162,6 +162,7 @@ public class BaseLifecycleBindable implements LifecycleBindable {
.switchMap(created -> created
? observable.observeOn(AndroidSchedulers.mainThread()).doOnCompleted(onCompletedAction)
: Observable.empty())
//TODO: basically takeUntil is calling completed so investigate observable = ***.first() behavior and doOnCompleted also
.takeUntil(conditionSubject.filter(condition -> condition))
.subscribe(onNextAction, throwable -> {
final boolean isRxError = throwable instanceof OnErrorThrowable;