Lines Matching refs:results1
472 auto results1 = w.make_subscriber<int>(); variable
497 w.schedule_absolute(300, [&s, &results1, &record](const rxsc::schedulable&){ in __anon2b91aec51f02()
498 s.get_observable().subscribe(results1); record(300);}); in __anon2b91aec51f02()
504 w.schedule_absolute(600, [&results1, &record](const rxsc::schedulable&){ in __anon2b91aec52202()
505 results1.unsubscribe(); record(600);}); in __anon2b91aec52202()
508 w.schedule_absolute(800, [&results1, &record](const rxsc::schedulable&){ in __anon2b91aec52402()
509 results1.unsubscribe(); record(800);}); in __anon2b91aec52402()
521 auto actual = results1.get_observer().messages();
587 auto results1 = w.make_subscriber<int>(); variable
604 w.schedule_absolute(300, [&s, &results1](const rxsc::schedulable&){ in __anon2b91aec52902()
605 s.get_observable().subscribe(results1);}); in __anon2b91aec52902()
611 w.schedule_absolute(600, [&results1](const rxsc::schedulable&){ in __anon2b91aec52c02()
612 results1.unsubscribe();}); in __anon2b91aec52c02()
615 w.schedule_absolute(800, [&results1](const rxsc::schedulable&){ in __anon2b91aec52e02()
616 results1.unsubscribe();}); in __anon2b91aec52e02()
628 auto actual = results1.get_observer().messages();
680 auto results1 = w.make_subscriber<int>(); variable
697 w.schedule_absolute(300, [&s, &results1](const rxsc::schedulable&){ in __anon2b91aec53302()
698 s.get_observable().subscribe(results1);}); in __anon2b91aec53302()
704 w.schedule_absolute(600, [&results1](const rxsc::schedulable&){ in __anon2b91aec53602()
705 results1.unsubscribe();}); in __anon2b91aec53602()
708 w.schedule_absolute(800, [&results1](const rxsc::schedulable&){ in __anon2b91aec53802()
709 results1.unsubscribe();}); in __anon2b91aec53802()
721 auto actual = results1.get_observer().messages();