Lines Matching refs:results3
476 auto results3 = w.make_subscriber<int>(); variable
501 w.schedule_absolute(900, [&s, &results3, &record](const rxsc::schedulable&){ in __anon6a6aec1e2102()
502 s.get_observable().subscribe(results3); record(900);}); in __anon6a6aec1e2102()
510 w.schedule_absolute(950, [&results3, &record](const rxsc::schedulable&){ in __anon6a6aec1e2502()
511 results3.unsubscribe(); record(950);}); in __anon6a6aec1e2502()
539 auto actual = results3.get_observer().messages();
591 auto results3 = w.make_subscriber<int>(); variable
608 w.schedule_absolute(900, [&s, &results3](const rxsc::schedulable&){ in __anon6a6aec1e2b02()
609 s.get_observable().subscribe(results3);}); in __anon6a6aec1e2b02()
617 w.schedule_absolute(950, [&results3](const rxsc::schedulable&){ in __anon6a6aec1e2f02()
618 results3.unsubscribe();}); in __anon6a6aec1e2f02()
646 auto actual = results3.get_observer().messages();
684 auto results3 = w.make_subscriber<int>(); variable
701 w.schedule_absolute(900, [&s, &results3](const rxsc::schedulable&){ in __anon6a6aec1e3502()
702 s.get_observable().subscribe(results3);}); in __anon6a6aec1e3502()
710 w.schedule_absolute(950, [&results3](const rxsc::schedulable&){ in __anon6a6aec1e3902()
711 results3.unsubscribe();}); in __anon6a6aec1e3902()
739 auto actual = results3.get_observer().messages();