diff --git a/src/main/java/rx/create/FromCallable.java b/src/main/java/rx/create/FromCallable.java new file mode 100644 index 0000000..d85872c --- /dev/null +++ b/src/main/java/rx/create/FromCallable.java @@ -0,0 +1,19 @@ +package rx.create; + +import io.reactivex.Flowable; + +/* + * Flowable = Observable + * fromCallable is another way of deferring. It creates an observable from the result of call. + * Please note that the callable is not being called asynchronously. It's just deferred until subscription. + */ +public class FromCallable { + public static void main(String[] args) { + System.out.println("current thread: " + Thread.currentThread()); + + Flowable.fromCallable(() -> { + System.out.println(Thread.currentThread() + ": returning 'hello world'"); + return "hello world"; + }).subscribe(); + } +}