use unicast subject

sockeqwe · Apr 8, 2018 · 513d1e9 · 513d1e9
1 parent 5f3b504
commit 513d1e9
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/mvi-common/src/main/java/com/hannesdorfmann/mosby3/mvi/MviBasePresenter.java b/mvi-common/src/main/java/com/hannesdorfmann/mosby3/mvi/MviBasePresenter.java
@@ -33,6 +33,7 @@
 import io.reactivex.subjects.BehaviorSubject;
 import io.reactivex.subjects.ReplaySubject;
 import io.reactivex.subjects.Subject;
+import io.reactivex.subjects.UnicastSubject;
 
 /**
  * This type of presenter is responsible for interaction with the viewState in a Model-View-Intent way.
@@ -449,7 +450,7 @@ protected void unbindIntents() {
      */
     @MainThread
     protected <I> Observable<I> intent(ViewIntentBinder<V, I> binder) {
-        Subject<I> intentRelay = ReplaySubject.create();
+        Subject<I> intentRelay = UnicastSubject.create();
         intentRelaysBinders.add(new IntentRelayBinderPair<I>(intentRelay, binder));
         return intentRelay;
     }