From cd00edc72ea0f49942598e94cc42866a43c9c178 Mon Sep 17 00:00:00 2001
From: Sander Hautvast <shautvast@ilionx.com>
Date: Tue, 11 Oct 2016 21:10:23 +0200
Subject: [PATCH] new example fromCallable

---
 src/main/java/rx/create/FromCallable.java | 19 +++++++++++++++++++
 1 file changed, 19 insertions(+)
 create mode 100644 src/main/java/rx/create/FromCallable.java

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();
+    }
+}