public interface JerseyFlowSubscriber<T> extends Flow.Subscriber<T>
Modifier and Type | Method and Description |
---|---|
default void |
onSubscribe(java.util.concurrent.Flow.Subscription subscription)
Method invoked prior to invoking any other Subscriber
methods for the given Subscription.
|
onComplete, onError, onNext
default void onSubscribe(java.util.concurrent.Flow.Subscription subscription)
Flow.Subscriber
Typically, implementations of this method invoke subscription.request
to enable receiving items.
onSubscribe
in interface Flow.Subscriber<T>
subscription
- a new subscriptionCopyright © 2007-2024, Oracle and/or its affiliates. All Rights Reserved. Use is subject to license terms.