@Test public void getObservable_shouldReturnCorrectClass() throws Exception { ObservableOnSubscribe<ConnectionStatus> observable = factory.getObservable(mock( LostApiClient.class)); assertThat(observable.getClass()).isEqualTo(DisposableConnectionStatusEmitter.class); }
@Override public ObservableOnSubscribe<ConnectionStatus> getObservable(LostApiClient client) { return new DisposableConnectionStatusEmitter(client); }
LostObservableFactory implements ObservableFactory { @Override public ObservableOnSubscribe<ConnectionStatus> getObservable(LostApiClient client) { return new DisposableConnectionStatusEmitter(client); } }
LostObservableFactory implements ObservableFactory { @Override public ObservableOnSubscribe<ConnectionStatus> getObservable(LostApiClient client) { return new DisposableConnectionStatusEmitter(client); } LostObservableFactory(); }
LostObservableFactory implements ObservableFactory { @Override public ObservableOnSubscribe<ConnectionStatus> getObservable(LostApiClient client) { return new DisposableConnectionStatusEmitter(client); } LostObservableFactory(); @Override ObservableOnSubscribe<ConnectionStatus> getObservable(LostApiClient client); }
LostObservableFactory implements ObservableFactory { @Override public ObservableOnSubscribe<ConnectionStatus> getObservable(LostApiClient client) { return new DisposableConnectionStatusEmitter(client); } LostObservableFactory(); @Override ObservableOnSubscribe<ConnectionStatus> getObservable(LostApiClient client);  }