emrekose26 · March 14, 2017 11:43 · Mar 14, 2017 · Mar 14, 2017 · Dec 3, 2015 · Dec 3, 2015
diff --git a/RxTransformer → RxTransformer.md b/RxTransformer → RxTransformer.md
diff --git a/README.md → RxTransformer b/README.md → RxTransformer
diff --git a/RxUtils.java → RxTransformer.java b/RxUtils.java → RxTransformer.java
@@ -3,7 +3,7 @@
 import rx.android.schedulers.AndroidSchedulers;
 import rx.schedulers.Schedulers;
 
-public class RxUtil {
+public class RxTransformer {
     /**
      * {@link rx.Observable.Transformer} that transforms the source observable to subscribe in the
      * io thread and observe on the Android's UI thread.

diff --git a/UseExample.java b/UseExample.java
@@ -1,4 +1,4 @@
             ApiService.getInstance().apiCall(parameter)
-                    .compose(RxUtil.applyIOToMainThreadSchedulers())
+                    .compose(RxTransformer.applyIOToMainThreadSchedulers())
                     .subscribe(data -> {});
 
diff --git a/README.me → README.md b/README.me → README.md
diff --git a/README.me b/README.me
@@ -0,0 +1,17 @@
+Problem
+```
+Error:(29, 37) error: cannot find symbol method subscribeOn(Scheduler)
+```
+
+This happens compiling this code borrowed from http://blog.danlew.net/2015/03/02/dont-break-the-chain/#comment-2388677116
+
+```java
+final Observable.Transformer schedulersTransformer =
+            observable -> observable.subscribeOn(Schedulers.io())
+                    .observeOn(AndroidSchedulers.mainThread());
+```
+
+Environment
+- Android Studio 2.0
+- Retrolambda
+- Compiled with Java 8
diff --git a/RxUtils.java b/RxUtils.java
@@ -0,0 +1,35 @@
+import rx.Observable;
+import rx.Subscription;
+import rx.android.schedulers.AndroidSchedulers;
+import rx.schedulers.Schedulers;
+
+public class RxUtil {
+    /**
+     * {@link rx.Observable.Transformer} that transforms the source observable to subscribe in the
+     * io thread and observe on the Android's UI thread.
+     */
+    private static Observable.Transformer ioToMainThreadSchedulerTransformer;
+
+    static {
+        ioToMainThreadSchedulerTransformer = createIOToMainThreadScheduler();
+    }
+
+    /**
+     * Get {@link rx.Observable.Transformer} that transforms the source observable to subscribe in
+     * the io thread and observe on the Android's UI thread.
+     *
+     * Because it doesn't interact with the emitted items it's safe ignore the unchecked casts.
+     *
+     * @return {@link rx.Observable.Transformer}
+     */
+    @SuppressWarnings("unchecked")
+    private static <T> Observable.Transformer<T, T> createIOToMainThreadScheduler() {
+        return tObservable -> tObservable.subscribeOn(Schedulers.io())
+                .observeOn(AndroidSchedulers.mainThread());
+    }
+
+    @SuppressWarnings("unchecked")
+    public static <T> Observable.Transformer<T, T> applyIOToMainThreadSchedulers() {
+        return ioToMainThreadSchedulerTransformer;
+    }
+}
diff --git a/UseExample.java b/UseExample.java
@@ -0,0 +1,4 @@
+            ApiService.getInstance().apiCall(parameter)
+                    .compose(RxUtil.applyIOToMainThreadSchedulers())
+                    .subscribe(data -> {});
+
No results found