@Test public void test_restart() throws Exception { ValueMap.Builder builder = ValueMap.builder(); RestartableSet set1 = new RestartableSet(builder); Subscription subscription = subscribeRestartable(method, subscriber1, scheduler, set1); launch(set1); subscription.unsubscribe(); ValueMap state = builder.build(); clearBackgroundObservables(); RestartableSet set = new RestartableSet(state, state.toBuilder()); subscribeRestartable(method, subscriber2, scheduler, set); advanceEmission(); verifyReceived(subscriber2); verifyNoLeakedObservables(); }
@Override public void launch(int id) { restartable(id).launch(); }
RestartableSet implements Launcher { @Override public void launch(int id) { restartable(id).launch(); } }
RestartableSet implements Launcher { @Override public void launch(int id) { restartable(id).launch(); } RestartableSet(ValueMap.Builder out);  RestartableSet(ValueMap in, ValueMap.Builder out); }
RestartableSet implements Launcher { @Override public void launch(int id) { restartable(id).launch(); } RestartableSet(ValueMap.Builder out);  RestartableSet(ValueMap in, ValueMap.Builder out); @Override Observable<Notification<T>> channel(int id, DeliveryMethod type, ObservableFactoryNoArg<T> observableFactoryNoArg); @Override Observable<Notification<T>> channel(int id, DeliveryMethod type, ObservableFactory<A, T> observableFactory); @Override void launch(int id); @Override void launch(int id, Object arg); @Override void dismiss(int id); void dismiss(); }
RestartableSet implements Launcher { @Override public void launch(int id) { restartable(id).launch(); } RestartableSet(ValueMap.Builder out);  RestartableSet(ValueMap in, ValueMap.Builder out); @Override Observable<Notification<T>> channel(int id, DeliveryMethod type, ObservableFactoryNoArg<T> observableFactoryNoArg); @Override Observable<Notification<T>> channel(int id, DeliveryMethod type, ObservableFactory<A, T> observableFactory); @Override void launch(int id); @Override void launch(int id, Object arg); @Override void dismiss(int id); void dismiss();  }