Lines Matching refs:results2
474 auto results2 = w.make_subscriber<int>(); variable
499 w.schedule_absolute(400, [&s, &results2, &record](const rxsc::schedulable&){ in __anon9dc5bb692002()
500 s.get_observable().subscribe(results2); record(400);}); in __anon9dc5bb692002()
506 w.schedule_absolute(700, [&results2, &record](const rxsc::schedulable&){ in __anon9dc5bb692302()
507 results2.unsubscribe(); record(700);}); in __anon9dc5bb692302()
531 auto actual = results2.get_observer().messages();
589 auto results2 = w.make_subscriber<int>(); variable
606 w.schedule_absolute(400, [&s, &results2](const rxsc::schedulable&){ in __anon9dc5bb692a02()
607 s.get_observable().subscribe(results2);}); in __anon9dc5bb692a02()
613 w.schedule_absolute(700, [&results2](const rxsc::schedulable&){ in __anon9dc5bb692d02()
614 results2.unsubscribe();}); in __anon9dc5bb692d02()
638 auto actual = results2.get_observer().messages();
682 auto results2 = w.make_subscriber<int>(); variable
699 w.schedule_absolute(400, [&s, &results2](const rxsc::schedulable&){ in __anon9dc5bb693402()
700 s.get_observable().subscribe(results2);}); in __anon9dc5bb693402()
706 w.schedule_absolute(700, [&results2](const rxsc::schedulable&){ in __anon9dc5bb693702()
707 results2.unsubscribe();}); in __anon9dc5bb693702()
731 auto actual = results2.get_observer().messages();