summaryrefslogtreecommitdiff
path: root/Rx/v2/test/operators/default_if_empty.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'Rx/v2/test/operators/default_if_empty.cpp')
-rw-r--r--Rx/v2/test/operators/default_if_empty.cpp167
1 files changed, 0 insertions, 167 deletions
diff --git a/Rx/v2/test/operators/default_if_empty.cpp b/Rx/v2/test/operators/default_if_empty.cpp
deleted file mode 100644
index 3acd73a..0000000
--- a/Rx/v2/test/operators/default_if_empty.cpp
+++ /dev/null
@@ -1,167 +0,0 @@
-#include "../test.h"
-#include <rxcpp/operators/rx-switch_if_empty.hpp>
-
-SCENARIO("default_if_empty should not switch if the source is not empty", "[default_if_empty][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(210, 1),
- on.completed(250)
- });
-
- WHEN("started"){
-
- auto res = w.start(
- [xs]() {
- return xs
- | rxo::default_if_empty(2)
- // forget type to workaround lambda deduction bug on msvc 2013
- | rxo::as_dynamic();
- }
- );
-
- THEN("the output only contains an item from the source") {
- auto required = rxu::to_vector({
- on.next(210, 1),
- 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("default_if_empty should switch if the source is empty", "[default_if_empty][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("started"){
-
- auto res = w.start(
- [xs]() {
- return xs
- .default_if_empty(2)
- // forget type to workaround lambda deduction bug on msvc 2013
- .as_dynamic();
- }
- );
-
- THEN("the output only contains an item from the backup source") {
- auto required = rxu::to_vector({
- on.next(250, 2),
- 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("default_if_empty - never", "[default_if_empty][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("started"){
-
- auto res = w.start(
- [xs]() {
- return xs
- .default_if_empty(2)
- // forget type to workaround lambda deduction bug on msvc 2013
- .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("default_if_empty - source throws", "[default_if_empty][operators]"){
- GIVEN("a source"){
- auto sc = rxsc::make_test();
- auto w = sc.create_worker();
- const rxsc::test::messages<int> on;
-
- std::runtime_error ex("default_if_empty on_error from source");
-
- auto xs = sc.make_hot_observable({
- on.next(150, 1),
- on.error(250, ex)
- });
-
- WHEN("started"){
-
- auto res = w.start(
- [xs]() {
- return xs
- .default_if_empty(2)
- // forget type to workaround lambda deduction bug on msvc 2013
- .as_dynamic();
- }
- );
-
- THEN("the output only contains an error from the source"){
- 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);
- }
- }
- }
-}