@Test public void cancelRemovesListenerAndStillAllowsOtherListenersToBeNotified() { CompletableProcessor processor = new CompletableProcessor(); rule.listen(processor).verifyNoEmissions(); rule2.listen(processor).verifyNoEmissions(); rule.cancel(); processor.onComplete(); rule.verifyNoEmissions(); rule2.verifyCompletion(); }
@Override public void onComplete() { terminate(complete()); }
CompletableProcessor extends Completable implements Processor { @Override public void onComplete() { terminate(complete()); } }
CompletableProcessor extends Completable implements Processor { @Override public void onComplete() { terminate(complete()); }  }
CompletableProcessor extends Completable implements Processor { @Override public void onComplete() { terminate(complete()); }  @Override void onSubscribe(Cancellable cancellable); @Override void onComplete(); @Override void onError(Throwable t); @Override void subscribe(final Subscriber subscriber); }
CompletableProcessor extends Completable implements Processor { @Override public void onComplete() { terminate(complete()); }  @Override void onSubscribe(Cancellable cancellable); @Override void onComplete(); @Override void onError(Throwable t); @Override void subscribe(final Subscriber subscriber);  }