Searched refs:onError (Results 1 – 4 of 4) sorted by relevance
250 public void onError(Throwable throwable); in onError() method
362 subscription.onError(ex); in subscribe()380 b.onError(new IllegalStateException("Duplicate subscribe")); in subscribe()678 b.onError(error); in closeExceptionally()944 public final void onError(Throwable ex) { in onError() method in SubmissionPublisher.ConsumerSubscriber1253 final void onError(Throwable ex) { in onError() method in SubmissionPublisher.BufferedSubscription1266 onError(null); in cancel()1279 onError(new IllegalArgumentException( in request()1425 s.onError(ex); in consumeError()
98 public synchronized void onError(Throwable t) { in onError() method in SubmissionPublisherTest.TestSubscriber1029 public void onError(Throwable t) { throw new AssertionError(t); }
15957 method public void onError(Throwable);