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 |
---|---|
PeekingOperators<T> |
PeekingOperators.onComplete(Runnable action)
Returns a stream containing all the elements from this stream, additionally performing the provided action when this
stream completes.
|
PeekingOperators<T> |
PeekingOperators.onError(Consumer<Throwable> errorHandler)
Returns a stream containing all the elements from this stream, additionally performing the provided action if this
stream conveys an error.
|
PeekingOperators<T> |
PeekingOperators.onTerminate(Runnable action)
Returns a stream containing all the elements from this stream, additionally performing the provided action when this
stream completes or failed.
|
PeekingOperators<T> |
PeekingOperators.peek(Consumer<? super T> consumer)
Returns a stream containing all the elements from this stream, additionally performing the provided action on each
element.
|
Copyright © 2019 Eclipse Foundation. All rights reserved.