@Test public void testErrorBeforeListen() { CompletableProcessor processor = new CompletableProcessor(); processor.onError(DELIBERATE_EXCEPTION); rule.listen(processor).verifyFailure(DELIBERATE_EXCEPTION); }
@Override public void onError(Throwable t) { terminate(TerminalNotification.error(t)); }
CompletableProcessor extends Completable implements Processor { @Override public void onError(Throwable t) { terminate(TerminalNotification.error(t)); } }
CompletableProcessor extends Completable implements Processor { @Override public void onError(Throwable t) { terminate(TerminalNotification.error(t)); }  }
CompletableProcessor extends Completable implements Processor { @Override public void onError(Throwable t) { terminate(TerminalNotification.error(t)); }  @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 onError(Throwable t) { terminate(TerminalNotification.error(t)); }  @Override void onSubscribe(Cancellable cancellable); @Override void onComplete(); @Override void onError(Throwable t); @Override void subscribe(final Subscriber subscriber);  }