modify operators' order

zhihu · Jan 23, 2017 · d6e262c · d6e262c
1 parent 6bac50d
commit d6e262c
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/README.md b/README.md
@@ -21,8 +21,8 @@ And then compose it to your original observable.
 
 ```
 Observable.interval(0, 2, TimeUnit.SECONDS)
-        .subscribeOn(Schedulers.computation())
         .compose(RxLifecycle.bind(MainActivity.this).<Long>withObservable())
+        .subscribeOn(Schedulers.computation())
         .observeOn(AndroidSchedulers.mainThread())
         .subscribe(new Consumer<Long>() {
             @Override

diff --git a/sample/src/main/java/cn/nekocode/rxlifecycle/sample/MainActivity.java b/sample/src/main/java/cn/nekocode/rxlifecycle/sample/MainActivity.java
@@ -109,8 +109,8 @@ public void accept(@LifecyclePublisher.Event Integer event) throws Exception {
 
     private void testFlowable() {
         Flowable.interval(0, 2, TimeUnit.SECONDS)
-                .subscribeOn(Schedulers.computation())
                 .compose(RxLifecycle.bind(this).<Long>withFlowable())
+                .subscribeOn(Schedulers.computation())
                 .observeOn(AndroidSchedulers.mainThread())
                 .subscribe(new Consumer<Long>() {
                     @Override
@@ -122,8 +122,8 @@ public void accept(Long n) throws Exception {
 
     private void testObservable() {
         Observable.interval(0, 2, TimeUnit.SECONDS)
-                .subscribeOn(Schedulers.computation())
                 .compose(RxLifecycle.bind(this).<Long>withObservable())
+                .subscribeOn(Schedulers.computation())
                 .observeOn(AndroidSchedulers.mainThread())
                 .subscribe(new Consumer<Long>() {
                     @Override