diff options
Diffstat (limited to 'Rx/v2/examples/doxygen/create.cpp')
-rw-r--r-- | Rx/v2/examples/doxygen/create.cpp | 100 |
1 files changed, 0 insertions, 100 deletions
diff --git a/Rx/v2/examples/doxygen/create.cpp b/Rx/v2/examples/doxygen/create.cpp deleted file mode 100644 index 1f707c6..0000000 --- a/Rx/v2/examples/doxygen/create.cpp +++ /dev/null @@ -1,100 +0,0 @@ -#include "rxcpp/rx.hpp" - -#include "rxcpp/rx-test.hpp" -#include "catch.hpp" - -SCENARIO("Create sample"){ - printf("//! [Create sample]\n"); - auto ints = rxcpp::observable<>::create<int>( - [](rxcpp::subscriber<int> s){ - s.on_next(1); - s.on_next(2); - s.on_completed(); - }); - - ints. - subscribe( - [](int v){printf("OnNext: %d\n", v);}, - [](){printf("OnCompleted\n");}); - printf("//! [Create sample]\n"); -} - -SCENARIO("Create bad code"){ - printf("//! [Create bad code]\n"); - auto subscription = rxcpp::composite_subscription(); - auto subscriber = rxcpp::make_subscriber<int>( - subscription, - [&](int v){ - printf("OnNext: %d\n", v); - if (v == 2) - subscription.unsubscribe(); - }, - [](){ - printf("OnCompleted\n"); - }); - rxcpp::observable<>::create<int>( - [](rxcpp::subscriber<int> s){ - for (int i = 0; i < 5; ++i) { - s.on_next(i); - printf("Just sent: OnNext(%d)\n", i); - } - s.on_completed(); - printf("Just sent: OnCompleted()\n"); - }).subscribe(subscriber); - printf("//! [Create bad code]\n"); -} - -SCENARIO("Create good code"){ - printf("//! [Create good code]\n"); - auto subscription = rxcpp::composite_subscription(); - auto subscriber = rxcpp::make_subscriber<int>( - subscription, - [&](int v){ - printf("OnNext: %d\n", v); - if (v == 2) - subscription.unsubscribe(); - }, - [](){ - printf("OnCompleted\n"); - }); - rxcpp::observable<>::create<int>( - [](rxcpp::subscriber<int> s){ - for (int i = 0; i < 5; ++i) { - if (!s.is_subscribed()) // Stop emitting if nobody is listening - break; - s.on_next(i); - printf("Just sent: OnNext(%d)\n", i); - } - s.on_completed(); - printf("Just sent: OnCompleted()\n"); - }).subscribe(subscriber); - printf("//! [Create good code]\n"); -} - -SCENARIO("Create great code"){ - printf("//! [Create great code]\n"); - auto ints = rxcpp::observable<>::create<int>( - [](rxcpp::subscriber<int> s){ - for (int i = 0; i < 5; ++i) { - if (!s.is_subscribed()) // Stop emitting if nobody is listening - break; - s.on_next(i); - printf("Just sent: OnNext(%d)\n", i); - } - s.on_completed(); - printf("Just sent: OnCompleted()\n"); - }); - ints. - take(2). - subscribe( - [](int v){ - printf("OnNext: %d\n", v); - }, - [](rxcpp::util::error_ptr ep){ - printf("OnError: %s\n", rxcpp::util::what(ep).c_str()); - }, - [](){ - printf("OnCompleted\n"); - }); - printf("//! [Create great code]\n"); -} |