diff options
author | Grigoriy Chudnov <g.chudnov@gmail.com> | 2016-12-29 12:43:27 +0300 |
---|---|---|
committer | Kirk Shoop <kirk.shoop@microsoft.com> | 2016-12-29 01:43:27 -0800 |
commit | c62234770349a638e0296ca0ceca137b4147af06 (patch) | |
tree | 53be49c7943cb93ec44a9c8d18ff4bfdd991d6d7 /Rx/v2/test/operators/timeout.cpp | |
parent | 2d10ccfb03439536bbe99cd750b30a4bdf7c31ce (diff) | |
download | RxCpp-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.cpp | 6 |
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)); } ); |