T
- The type of the elements that the subscriber consumes.R
- The type of the result that the subscriber emits.public interface SubscriberWithCompletionStage<T,R>
Modifier and Type | Method and Description |
---|---|
CompletionStage<R> |
getCompletion()
Get the completion stage.
|
org.reactivestreams.Subscriber<T> |
getSubscriber()
Get the subscriber.
|
CompletionStage<R> getCompletion()
This should be redeemed by the subscriber either when it cancels, or when it receives an
Subscriber.onComplete()
signal or an Subscriber.onError(Throwable)
signal. Generally, the redeemed
value or error should be the result of consuming the stream.
org.reactivestreams.Subscriber<T> getSubscriber()
Copyright © 2019 Eclipse Foundation. All rights reserved.