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