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