Lines Matching refs:results3
476 auto results3 = w.make_subscriber<int>(); variable
501 w.schedule_absolute(900, [&s, &results3, &record](const rxsc::schedulable&){ in __anon0164c1a72102()
502 s.get_observable().subscribe(results3); record(900);}); in __anon0164c1a72102()
510 w.schedule_absolute(950, [&results3, &record](const rxsc::schedulable&){ in __anon0164c1a72502()
511 results3.unsubscribe(); record(950);}); in __anon0164c1a72502()
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 __anon0164c1a72b02()
609 s.get_observable().subscribe(results3);}); in __anon0164c1a72b02()
617 w.schedule_absolute(950, [&results3](const rxsc::schedulable&){ in __anon0164c1a72f02()
618 results3.unsubscribe();}); in __anon0164c1a72f02()
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 __anon0164c1a73502()
702 s.get_observable().subscribe(results3);}); in __anon0164c1a73502()
710 w.schedule_absolute(950, [&results3](const rxsc::schedulable&){ in __anon0164c1a73902()
711 results3.unsubscribe();}); in __anon0164c1a73902()
739 auto actual = results3.get_observer().messages();