summaryrefslogtreecommitdiff
path: root/Rx/v2/test/operators/timeout.cpp
diff options
context:
space:
mode:
authorGrigoriy Chudnov <g.chudnov@gmail.com>2016-12-29 12:43:27 +0300
committerKirk Shoop <kirk.shoop@microsoft.com>2016-12-29 01:43:27 -0800
commitc62234770349a638e0296ca0ceca137b4147af06 (patch)
tree53be49c7943cb93ec44a9c8d18ff4bfdd991d6d7 /Rx/v2/test/operators/timeout.cpp
parent2d10ccfb03439536bbe99cd750b30a4bdf7c31ce (diff)
downloadRxCpp-c62234770349a638e0296ca0ceca137b4147af06.tar.gz
decouple timeout from observable (#304)
* decouple timeout from observable * fix bad merge
Diffstat (limited to 'Rx/v2/test/operators/timeout.cpp')
-rw-r--r--Rx/v2/test/operators/timeout.cpp6
1 files changed, 4 insertions, 2 deletions
diff --git a/Rx/v2/test/operators/timeout.cpp b/Rx/v2/test/operators/timeout.cpp
index 61d67a6..3005209 100644
--- a/Rx/v2/test/operators/timeout.cpp
+++ b/Rx/v2/test/operators/timeout.cpp
@@ -1,4 +1,5 @@
#include "../test.h"
+#include "rxcpp/operators/rx-timeout.hpp"
using namespace std::chrono;
@@ -17,7 +18,8 @@ SCENARIO("should not timeout if the source never emits any items", "[timeout][op
auto res = w.start(
[so, xs]() {
- return xs.timeout(milliseconds(10), so);
+ return xs
+ | rxo::timeout(milliseconds(10), so);
}
);
@@ -54,7 +56,7 @@ SCENARIO("should not timeout if the source observable is empty", "[timeout][oper
auto res = w.start(
[so, xs]() {
- return xs.timeout(milliseconds(10), so);
+ return xs.timeout(so, milliseconds(10));
}
);