Package | Description |
---|---|
org.eclipse.microprofile.reactive.streams.operators |
Modifier and Type | Interface and Description |
---|---|
interface |
ProcessorBuilder<T,R>
A builder for a
Processor . |
interface |
PublisherBuilder<T>
A builder for a
Publisher . |
Modifier and Type | Method and Description |
---|---|
ErrorHandlingOperators<T> |
ErrorHandlingOperators.onErrorResume(Function<Throwable,? extends T> errorHandler)
Returns a stream containing all the elements from this stream.
|
ErrorHandlingOperators<T> |
ErrorHandlingOperators.onErrorResumeWith(Function<Throwable,? extends PublisherBuilder<? extends T>> errorHandler)
Returns a stream containing all the elements from this stream.
|
ErrorHandlingOperators<T> |
ErrorHandlingOperators.onErrorResumeWithRsPublisher(Function<Throwable,? extends org.reactivestreams.Publisher<? extends T>> errorHandler)
Returns a stream containing all the elements from this stream.
|
Copyright © 2019 Eclipse Foundation. All rights reserved.