@Test public void dispose_disconnect() throws Exception { emitter.dispose(); verify(client).disconnect(); }
@Override public void dispose() { disposed = true; client.unregisterConnectionCallbacks(this); client.disconnect(); }
DisposableConnectionStatusEmitter implements ObservableOnSubscribe<ConnectionStatus>,
    Disposable, LostApiClient.ConnectionCallbacks { @Override public void dispose() { disposed = true; client.unregisterConnectionCallbacks(this); client.disconnect(); } }
DisposableConnectionStatusEmitter implements ObservableOnSubscribe<ConnectionStatus>,
    Disposable, LostApiClient.ConnectionCallbacks { @Override public void dispose() { disposed = true; client.unregisterConnectionCallbacks(this); client.disconnect(); } DisposableConnectionStatusEmitter(LostApiClient client); }
DisposableConnectionStatusEmitter implements ObservableOnSubscribe<ConnectionStatus>,
    Disposable, LostApiClient.ConnectionCallbacks { @Override public void dispose() { disposed = true; client.unregisterConnectionCallbacks(this); client.disconnect(); } DisposableConnectionStatusEmitter(LostApiClient client); @Override void subscribe(final ObservableEmitter<ConnectionStatus> emitter); @Override void dispose(); @Override boolean isDisposed(); @Override void onConnected(); @Override void onConnectionSuspended(); }
DisposableConnectionStatusEmitter implements ObservableOnSubscribe<ConnectionStatus>,
    Disposable, LostApiClient.ConnectionCallbacks { @Override public void dispose() { disposed = true; client.unregisterConnectionCallbacks(this); client.disconnect(); } DisposableConnectionStatusEmitter(LostApiClient client); @Override void subscribe(final ObservableEmitter<ConnectionStatus> emitter); @Override void dispose(); @Override boolean isDisposed(); @Override void onConnected(); @Override void onConnectionSuspended();  }