diff --git a/src/main/java/ru/touchin/roboswag/components/utils/BaseLifecycleBindable.java b/src/main/java/ru/touchin/roboswag/components/utils/BaseLifecycleBindable.java index 6cb7ff4..61a9f6d 100644 --- a/src/main/java/ru/touchin/roboswag/components/utils/BaseLifecycleBindable.java +++ b/src/main/java/ru/touchin/roboswag/components/utils/BaseLifecycleBindable.java @@ -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;