Interface Stage.SubscriberStage

  • All Superinterfaces:
    Stage
    Enclosing interface:
    Stage

    public static interface Stage.SubscriberStage
    extends Stage
    A subscriber.

    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.

    • Method Detail

      • getRsSubscriber

        org.reactivestreams.Subscriber<?> getRsSubscriber()
        The subscriber.
        Returns:
        The subscriber.