public static interface Stage.SubscriberStage extends Stage
When built, the CompletionStage
must emit null
when the stream completes normally, or an
error if the stream terminates with an error.
Implementing this will typically require inserting a handler before the subscriber that listens for errors.
Stage.Cancel, Stage.Collect, Stage.Concat, Stage.Coupled, Stage.Distinct, Stage.DropWhile, Stage.Failed, Stage.Filter, Stage.FindFirst, Stage.FlatMap, Stage.FlatMapCompletionStage, Stage.FlatMapIterable, Stage.FromCompletionStage, Stage.FromCompletionStageNullable, Stage.Limit, Stage.Map, Stage.Of, Stage.OnComplete, Stage.OnError, Stage.OnErrorResume, Stage.OnErrorResumeWith, Stage.OnTerminate, Stage.Peek, Stage.ProcessorStage, Stage.PublisherStage, Stage.Skip, Stage.SubscriberStage, Stage.TakeWhile
Modifier and Type | Method and Description |
---|---|
org.reactivestreams.Subscriber<?> |
getRsSubscriber()
The subscriber.
|
Copyright © 2019 Eclipse Foundation. All rights reserved.