Add description and examples for observable<T> members

1 files changed, 10 insertions, 3 deletions

diff --git a/Rx/v2/examples/doxygen/from.cpp b/Rx/v2/examples/doxygen/from.cpp
index 03288eb..15186ba 100644
--- a/Rx/v2/examples/doxygen/from.cpp
+++ b/Rx/v2/examples/doxygen/from.cpp
@@ -13,14 +13,21 @@ SCENARIO("from sample"){
     printf("//! [from sample]\n");
 }
 
+std::string get_pid();
+
 SCENARIO("threaded from sample"){
     printf("//! [threaded from sample]\n");
-    auto values = rxcpp::observable<>::from(rxcpp::observe_on_event_loop(), 1, 2, 3);
+    printf("[thread %s] Start task\n", get_pid().c_str());
+    auto values = rxcpp::observable<>::from(rxcpp::observe_on_new_thread(), 1, 2, 3).map([](int v){
+        printf("[thread %s] Emit value: %d\n", get_pid().c_str(), v);
+        return v;
+    });
     values.
         as_blocking().
         subscribe(
-            [](int v){printf("OnNext: %d\n", v);},
-            [](){printf("OnCompleted\n");});
+            [](int v){printf("[thread %s] OnNext: %d\n", get_pid().c_str(), v);},
+            [](){printf("[thread %s] OnCompleted\n", get_pid().c_str());});
+    printf("[thread %s] Finish task\n", get_pid().c_str());
     printf("//! [threaded from sample]\n");
 }