blob: e9e62c2a06055837cc89dd6107118ecd8eb3a0b3 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
|
#include "rxcpp/rx.hpp"
namespace rx=rxcpp;
namespace rxu=rxcpp::util;
namespace rxsc=rxcpp::schedulers;
#include "rxcpp/rx-test.hpp"
#include "catch.hpp"
SCENARIO("defer stops on completion", "[defer][sources]"){
GIVEN("a test cold observable of ints"){
auto sc = rxsc::make_test();
auto w = sc.create_worker();
const rxsc::test::messages<long> on;
long invoked = 0;
rxu::detail::maybe<rx::test::testable_observable<long>> xs;
WHEN("deferred"){
auto empty = rx::observable<>::empty<long>();
auto just = rx::observable<>::just(42);
auto one = rx::observable<>::from(42);
auto error = rx::observable<>::error<long>(std::exception_ptr());
auto runtimeerror = rx::observable<>::error<long>(std::runtime_error("runtime"));
auto res = w.start(
[&]() {
return rx::observable<>::defer(
[&](){
invoked++;
xs.reset(sc.make_cold_observable({
on.on_next(100, sc.clock()),
on.on_completed(200)
}));
return xs.get();
})
// forget type to workaround lambda deduction bug on msvc 2013
.as_dynamic();
}
);
THEN("the output stops on completion"){
auto required = rxu::to_vector({
on.on_next(300, 200L),
on.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.get().subscriptions();
REQUIRE(required == actual);
}
THEN("defer was called until completed"){
REQUIRE(1 == invoked);
}
}
}
}
|
