diff options
Diffstat (limited to 'Rx/v2/test/operators/map.cpp')
| -rw-r--r-- | Rx/v2/test/operators/map.cpp | 240 |
1 files changed, 0 insertions, 240 deletions
diff --git a/Rx/v2/test/operators/map.cpp b/Rx/v2/test/operators/map.cpp deleted file mode 100644 index c96cc8d..0000000 --- a/Rx/v2/test/operators/map.cpp +++ /dev/null @@ -1,240 +0,0 @@ -#include "../test.h" -#include <rxcpp/operators/rx-map.hpp> - -SCENARIO("map stops on completion", "[map][operators]") { - GIVEN("a test hot observable of ints") { - auto sc = rxsc::make_test(); - auto w = sc.create_worker(); - const rxsc::test::messages<int> on; - long invoked = 0; - - auto xs = sc.make_hot_observable({ - on.next(180, 1), - on.next(210, 2), - on.next(240, 3), - on.next(290, 4), - on.next(350, 5), - on.completed(400), - on.next(410, -1), - on.completed(420), - on.error(430, std::runtime_error("error on unsubscribed stream")) - }); - - WHEN("mapped to ints that are one larger") { - - auto res = w.start( - [xs, &invoked]() { - return xs - .map([&invoked](int x) { - invoked++; - return x + 1; - }) - // forget type to workaround lambda deduction bug on msvc 2013 - .as_dynamic(); - } - ); - - THEN("the output stops on completion") { - auto required = rxu::to_vector({ - on.next(210, 3), - on.next(240, 4), - on.next(290, 5), - on.next(350, 6), - on.completed(400) - }); - auto actual = res.get_observer().messages(); - REQUIRE(required == actual); - } - - THEN("there was one subscription and one unsubscription") { - auto required = rxu::to_vector({ - on.subscribe(200, 400) - }); - auto actual = xs.subscriptions(); - REQUIRE(required == actual); - } - - THEN("map was called until completed") { - REQUIRE(4 == invoked); - } - } - } -} - -SCENARIO("map - never", "[map][operators]") { - GIVEN("a source") { - auto sc = rxsc::make_test(); - auto w = sc.create_worker(); - const rxsc::test::messages<int> on; - - auto xs = sc.make_hot_observable({ - on.next(150, 1) - }); - - WHEN("values are mapped") { - - auto res = w.start( - [xs]() { - return xs - | rxo::map([](int x) { - return x + 1; - }) - // forget type to workaround lambda deduction bug on msvc 2013 - | rxo::as_dynamic(); - } - ); - - THEN("the output is empty") { - auto required = std::vector<rxsc::test::messages<int>::recorded_type>(); - auto actual = res.get_observer().messages(); - REQUIRE(required == actual); - } - - THEN("there was 1 subscription/unsubscription to the source") { - auto required = rxu::to_vector({ - on.subscribe(200, 1000) - }); - auto actual = xs.subscriptions(); - REQUIRE(required == actual); - } - } - } -} - -SCENARIO("map - empty", "[map][operators]") { - GIVEN("a source") { - auto sc = rxsc::make_test(); - auto w = sc.create_worker(); - const rxsc::test::messages<int> on; - - auto xs = sc.make_hot_observable({ - on.next(150, 1), - on.completed(250) - }); - - WHEN("values are mapped") { - - auto res = w.start( - [xs]() { - return xs - .map([](int x) { - return x + 1; - }) - // forget type to workaround lambda deduction bug on msvc 2013 - .as_dynamic(); - } - ); - - THEN("the output only contains complete message") { - auto required = rxu::to_vector({ - on.completed(250) - }); - auto actual = res.get_observer().messages(); - REQUIRE(required == actual); - } - - THEN("there was 1 subscription/unsubscription to the source") { - auto required = rxu::to_vector({ - on.subscribe(200, 250) - }); - auto actual = xs.subscriptions(); - REQUIRE(required == actual); - } - - } - } -} - -SCENARIO("map - items emitted", "[map][operators]") { - GIVEN("a source") { - auto sc = rxsc::make_test(); - auto w = sc.create_worker(); - const rxsc::test::messages<int> on; - - auto xs = sc.make_hot_observable({ - on.next(150, 1), - on.next(210, 2), - on.next(240, 3), - on.completed(300) - }); - - WHEN("values are mapped") { - - auto res = w.start( - [xs]() { - return xs - .map([](int x) { - return x + 1; - }) - // forget type to workaround lambda deduction bug on msvc 2013 - .as_dynamic(); - } - ); - - THEN("the output only contains items sent while subscribed") { - auto required = rxu::to_vector({ - on.next(210, 3), - on.next(240, 4), - on.completed(300) - }); - auto actual = res.get_observer().messages(); - REQUIRE(required == actual); - } - - THEN("there was 1 subscription/unsubscription to the source") { - auto required = rxu::to_vector({ - on.subscribe(200, 300) - }); - auto actual = xs.subscriptions(); - REQUIRE(required == actual); - } - - } - } -} - -SCENARIO("map - throw", "[map][operators]") { - GIVEN("a source") { - auto sc = rxsc::make_test(); - auto w = sc.create_worker(); - const rxsc::test::messages<int> on; - - std::runtime_error ex("map on_error from source"); - - auto xs = sc.make_hot_observable({ - on.next(150, 1), - on.error(250, ex) - }); - - WHEN("values are mapped") { - - auto res = w.start( - [xs]() { - return xs - .map([](int x) { - return x + 1; - }) - // forget type to workaround lambda deduction bug on msvc 2013 - .as_dynamic(); - } - ); - - THEN("the output only contains only error") { - auto required = rxu::to_vector({ - on.error(250, ex) - }); - auto actual = res.get_observer().messages(); - REQUIRE(required == actual); - } - - THEN("there was 1 subscription/unsubscription to the source") { - auto required = rxu::to_vector({ - on.subscribe(200, 250) - }); - auto actual = xs.subscriptions(); - REQUIRE(required == actual); - } - - } - } -} |