1 files changed, 0 insertions, 121 deletions
diff --git a/Rx/v2/test/operators/tap.cpp b/Rx/v2/test/operators/tap.cpp
deleted file mode 100644
index c9e8317..0000000
--- a/Rx/v2/test/operators/tap.cpp
+++ /dev/null
@@ -1,121 +0,0 @@
-#include "../test.h"
-#include <rxcpp/operators/rx-tap.hpp>
-
-SCENARIO("tap stops on completion", "[tap][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("on_next is tapped"){
-
-            auto res = w.start(
-                [xs, &invoked]() {
-                    return xs
-                        | rxo::tap([&invoked](int) {
-                            invoked++;
-                        })
-                        // forget type to workaround lambda deduction bug on msvc 2013
-                        | rxo::as_dynamic();
-                }
-            );
-
-            THEN("the output stops on completion"){
-                auto required = rxu::to_vector({
-                    on.next(210, 2),
-                    on.next(240, 3),
-                    on.next(290, 4),
-                    on.next(350, 5),
-                    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("tap on_next was called until completed"){
-                REQUIRE(4 == invoked);
-            }
-        }
-    }
-}
-
-SCENARIO("tap stops on error", "[tap][operators]"){
-    GIVEN("a test hot observable of ints"){
-        auto sc = rxsc::make_test();
-        auto w = sc.create_worker();
-        const rxsc::test::messages<int> on;
-        std::runtime_error ex("tap on_error from source");
-        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.error(300, ex),
-            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("on_error is tapped"){
-
-            auto res = w.start(
-                [xs, &invoked]() {
-                    return xs
-                        .tap([&invoked](rxu::error_ptr) {
-                            invoked++;
-                        })
-                        // 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, 2),
-                    on.next(240, 3),
-                    on.next(290, 4),
-                    on.error(300, ex)
-                });
-                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, 300)
-                });
-                auto actual = xs.subscriptions();
-                REQUIRE(required == actual);
-            }
-
-            THEN("tap on_next was called until completed"){
-                REQUIRE(1 == invoked);
-            }
-        }
-    }
-}