Fix singleReducerBindable

izumin5210 · Jan 2, 2018 · b4de3ba · b4de3ba
1 parent 4163348
commit b4de3ba
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/droidux-processor/src/test/java/info/izumin/android/droidux/processor/fixture/Source.java b/droidux-processor/src/test/java/info/izumin/android/droidux/processor/fixture/Source.java
@@ -184,11 +184,11 @@ public static class BindableCounter {
                 "import info.izumin.android.droidux.BaseStore;",
                 "import info.izumin.android.droidux.processor.fixture.Counter;",
                 "import info.izumin.android.droidux.processor.fixture.CounterReducer;",
-                "import io.reactivex.Observable;",
+                "import io.reactivex.Flowable;",
                 "@Store({CounterReducer.class})",
                 "public interface RootStore extends BaseStore, android.databinding.Observable {",
                 "    @Bindable Counter counter();",
-                "    Observable<Counter> observeCounter();",
+                "    Flowable<Counter> observeCounter();",
                 "}"
         };
 
@@ -203,9 +203,9 @@ public static class BindableCounter {
                 "import info.izumin.android.droidux.exception.NotInitializedException;",
                 "import info.izumin.android.droidux.processor.fixture.Counter;",
                 "import info.izumin.android.droidux.processor.fixture.CounterReducer;",
+                "import io.reactivex.Flowable;",
                 "import java.util.ArrayList;",
                 "import java.util.List;",
-                "import io.reactivex.Observable;",
                 "",
                 "public final class DroiduxRootStore extends BaseObservable implements RootStore {",
                 "    private final DroiduxRootStore_CounterStoreImpl counterStoreImpl;",
@@ -235,12 +235,12 @@ public static class BindableCounter {
                 "    }",
                 "",
                 "    @Override",
-                "    public Observable<Counter> observeCounter() {",
+                "    public Flowable<Counter> observeCounter() {",
                 "        return counterStoreImpl.observe();",
                 "    }",
                 "",
                 "    @Override",
-                "    public Observable<Action> dispatch(Action action) {",
+                "    public Flowable<Action> dispatch(Action action) {",
                 "        return dispatcher.dispatch(action)",
                 "    }",
                 "",