@Test public void testErrorBeforeListen() { SingleProcessor<String> processor = new SingleProcessor<>(); processor.onError(DELIBERATE_EXCEPTION); rule().listen(processor).verifyFailure(DELIBERATE_EXCEPTION); }
@Override public void onError(final Throwable t) { terminate(TerminalNotification.error(t)); }
SingleProcessor extends Single<T> implements Processor<T, T> { @Override public void onError(final Throwable t) { terminate(TerminalNotification.error(t)); } }
SingleProcessor extends Single<T> implements Processor<T, T> { @Override public void onError(final Throwable t) { terminate(TerminalNotification.error(t)); }  }
SingleProcessor extends Single<T> implements Processor<T, T> { @Override public void onError(final Throwable t) { terminate(TerminalNotification.error(t)); }  @Override void onSubscribe(final Cancellable cancellable); @Override void onSuccess(@Nullable final T result); @Override void onError(final Throwable t); @Override void subscribe(final Subscriber<? super T> subscriber); }
SingleProcessor extends Single<T> implements Processor<T, T> { @Override public void onError(final Throwable t) { terminate(TerminalNotification.error(t)); }  @Override void onSubscribe(final Cancellable cancellable); @Override void onSuccess(@Nullable final T result); @Override void onError(final Throwable t); @Override void subscribe(final Subscriber<? super T> subscriber);  }