Lines Matching refs:rx
45 rx::observable<>::just(1) in __anoncf43e2d30302()
90 rx::observable<>::just(1) in __anoncf43e2d30702()
93 }, rx::observable<>::just(2)) in __anoncf43e2d30702()
121 auto es = rx::synchronize_event_loop();
130 auto liftrequirecompletion = [&](rx::subscriber<int> dest){ in __anoncf43e2d30a02()
131 …auto completionstate = std::make_shared<std::tuple<bool, long, rx::subscriber<int>>>(false, 0, std… in __anoncf43e2d30a02()
138 return rx::make_subscriber<int>( in __anoncf43e2d30a02()
166 rx::make_observer_dynamic<int>( in __anoncf43e2d30a02()
181 rx::make_observer_dynamic<int>( in __anoncf43e2d30a02()
196 rx::make_observer_dynamic<int>( in __anoncf43e2d30a02()
230 auto es = rx::observe_on_event_loop();
239 auto liftrequirecompletion = [&](rx::subscriber<int> dest){ in __anoncf43e2d31602()
240 …auto completionstate = std::make_shared<std::tuple<bool, long, rx::subscriber<int>>>(false, 0, std… in __anoncf43e2d31602()
247 return rx::make_subscriber<int>( in __anoncf43e2d31602()
274 rx::make_observer_dynamic<int>( in __anoncf43e2d31602()
288 rx::make_observer_dynamic<int>( in __anoncf43e2d31602()
302 rx::make_observer_dynamic<int>( in __anoncf43e2d31602()
329 auto es = rx::make_subscription();
330 rx::composite_subscription cs;
333 REQUIRE(rx::is_subscription<decltype(es)>::value);
336 REQUIRE(rx::is_subscription<decltype(cs)>::value);
350 REQUIRE(!rx::is_subscription<decltype(l)>::value);
354 REQUIRE(!rx::is_subscription<decltype(i)>::value);
358 REQUIRE(!rx::is_subscription<decltype(v)>::value);
361 REQUIRE(!rx::is_subscription<void>::value);
370 auto s = rx::make_subscription([&i](){++i;}); in __anoncf43e2d32302()
404 auto s = rx::make_subscription();
427 rx::composite_subscription s;
428 s.add(rx::make_subscription());
429 s.add(rx::make_subscription([&i](){++i;})); in __anoncf43e2d32402()