From ffcc6bb2442a0e8786ea80baac4950bc6e5b2a57 Mon Sep 17 00:00:00 2001
From: Alexander Bubnov <alex.bubnov@touchin.ru>
Date: Tue, 28 Mar 2017 14:21:58 +0300
Subject: [PATCH] important fix

---
 .../utils/BaseLifecycleBindable.java           | 18 +++++++++---------
 1 file changed, 9 insertions(+), 9 deletions(-)

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 c046215..ff35b48 100644
--- a/src/main/java/ru/touchin/roboswag/components/utils/BaseLifecycleBindable.java
+++ b/src/main/java/ru/touchin/roboswag/components/utils/BaseLifecycleBindable.java
@@ -251,20 +251,20 @@ public class BaseLifecycleBindable implements LifecycleBindable {
             actualObservable = observable.observeOn(AndroidSchedulers.mainThread())
                     .doOnCompleted(onCompletedAction)
                     .doOnNext(onNextAction)
-                    .onErrorResumeNext(throwable -> {
-                        final boolean isRxError = throwable instanceof OnErrorThrowable;
-                        if ((!isRxError && throwable instanceof RuntimeException)
-                                || (isRxError && throwable.getCause() instanceof RuntimeException)) {
-                            Lc.assertion(throwable);
-                        }
-                        onErrorAction.call(throwable);
-                        return Observable.empty();
-                    });
+                    .doOnError(onErrorAction);
         }
 
         return isCreatedSubject.first()
                 .switchMap(created -> created ? actualObservable : Observable.empty())
                 .takeUntil(conditionSubject.filter(condition -> condition))
+                .onErrorResumeNext(throwable -> {
+                    final boolean isRxError = throwable instanceof OnErrorThrowable;
+                    if ((!isRxError && throwable instanceof RuntimeException)
+                            || (isRxError && throwable.getCause() instanceof RuntimeException)) {
+                        Lc.assertion(throwable);
+                    }
+                    return Observable.empty();
+                })
                 .subscribe();
     }