summaryrefslogtreecommitdiff
path: root/Rx/v2/examples/doxygen/create.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'Rx/v2/examples/doxygen/create.cpp')
-rw-r--r--Rx/v2/examples/doxygen/create.cpp100
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");
-}