Searched refs:closeOnError (Results 1 – 1 of 1) sorted by relevance
1297 closeOnError(s, null); in consume()1372 closeOnError(s, ex); in handleOnNext()1388 closeOnError(s, ex); in consumeSubscribe()1411 final void closeOnError(Subscriber<? super T> s, Throwable ex) { in closeOnError() method in SubmissionPublisher.BufferedSubscription