T
- The type of the elements that this subscriber consumes.R
- The type of the result that this subscriber emits.public interface SubscriberBuilder<T,R> extends ProducesResult<R>
Subscriber
and its result.
When built, this builder returns a CompletionSubscriber
, which encapsulates both a
Subscriber
and a CompletionStage
that will be redeemed with
the result produced by the subscriber when the stream completes normally, or will be redeemed with an error if the
subscriber receives an error. A SubscriberBuilder
may represent a compound set of stream stages and may
complete exceptionally without receiving an error externally. Similarly, SubscriberBuilder
s may encapsulate
error handling such as the onErrorResume operator and recover from an externally received errors.
ReactiveStreams
Modifier and Type | Method and Description |
---|---|
CompletionSubscriber<T,R> |
build()
Build this stream, using the first
ReactiveStreamsEngine found by the ServiceLoader . |
CompletionSubscriber<T,R> |
build(ReactiveStreamsEngine engine)
Build this stream, using the supplied
ReactiveStreamsEngine . |
CompletionSubscriber<T,R> build()
ReactiveStreamsEngine
found by the ServiceLoader
.CompletionSubscriber
that will run this stream.CompletionSubscriber<T,R> build(ReactiveStreamsEngine engine)
ReactiveStreamsEngine
.engine
- The engine to run the stream with.CompletionSubscriber
that will run this stream.Copyright © 2018 – 2022 Eclipse Foundation. All rights reserved.
Use is subject to license terms.