Lines Matching refs:rx
19 auto scrbResult = rx::make_subscriber<int>(next, error, completed);
20 auto scrbdup = rx::make_subscriber<int>(scrbResult);
21 auto scrbop = rx::make_subscriber<int>(scrbResult, next, error, completed);
22 auto scrbsharelifetime = rx::make_subscriber<int>(scrbResult, scrbop.get_observer());
23 … auto scrbuniquelifetime = rx::make_subscriber<int>(scrbResult, rx::composite_subscription());
26 auto scrb = rx::make_subscriber<int>(emptyNext);
29 REQUIRE(rx::is_observer<decltype(scrb)>::value);
32 REQUIRE(rx::is_subscription<decltype(scrb)>::value);
64 auto dob = rx::make_observer_dynamic<int>(emptyNext);
65 auto so = rx::make_observer<int>(emptyNext);
66 auto eo = rx::make_observer<int>();
69 REQUIRE(rx::is_observer<decltype(dob)>::value);
72 REQUIRE(rx::is_observer<decltype(so)>::value);
75 REQUIRE(rx::is_observer<decltype(eo)>::value);
84 rx::static_subscription<decltype(empty)> ss(empty);
85 auto es = rx::make_subscription();
86 rx::composite_subscription cs;
89 REQUIRE(!rx::is_observer<decltype(ss)>::value);
92 REQUIRE(!rx::is_observer<decltype(es)>::value);
95 REQUIRE(!rx::is_observer<decltype(cs)>::value);
107 auto dob = rx::make_subscriber<int>(rx::make_observer_dynamic<int>(next, error, completed));
108 auto so = rx::make_subscriber<int>(next, error, completed);