getTestScheduler().flush(); // flush the observables