summaryrefslogtreecommitdiff
path: root/Rx/v2/test/operators/ignore_elements.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'Rx/v2/test/operators/ignore_elements.cpp')
-rw-r--r--Rx/v2/test/operators/ignore_elements.cpp160
1 files changed, 0 insertions, 160 deletions
diff --git a/Rx/v2/test/operators/ignore_elements.cpp b/Rx/v2/test/operators/ignore_elements.cpp
deleted file mode 100644
index fdf856d..0000000
--- a/Rx/v2/test/operators/ignore_elements.cpp
+++ /dev/null
@@ -1,160 +0,0 @@
-#include "../test.h"
-#include <rxcpp/operators/rx-ignore_elements.hpp>
-
-SCENARIO("ignore_elements - never", "[ignore_elements][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("ignore_elements is applied"){
-
- auto res = w.start(
- [xs]() {
- return xs | rxo::ignore_elements();
- }
- );
-
- 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("ignore_elements - empty", "[ignore_elements][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("ignore_elements is applied"){
-
- auto res = w.start(
- [xs]() {
- return xs.ignore_elements();
- }
- );
-
- THEN("the output contains the completion 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("ignore_elements - throw", "[ignore_elements][operators]"){
- GIVEN("a source"){
- auto sc = rxsc::make_test();
- auto w = sc.create_worker();
- const rxsc::test::messages<int> on;
-
- std::runtime_error ex("ignore_elements on_error from source");
-
- auto xs = sc.make_hot_observable({
- on.next(150, 1),
- on.error(250, ex)
- });
-
- WHEN("ignore_elements is applied"){
-
- auto res = w.start(
- [xs]() {
- return xs.ignore_elements();
- }
- );
-
- THEN("the output contains an 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);
- }
-
- }
- }
-}
-
-SCENARIO("ignore_elements - items", "[ignore_elements][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(220, 3),
- on.next(230, 4),
- on.next(240, 5),
- on.completed(250)
- });
-
- WHEN("ignore_elements is applied"){
-
- auto res = w.start(
- [xs]() {
- return xs.ignore_elements();
- }
- );
-
- THEN("the output contains the completion 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);
- }
-
- }
- }
-}