public static class JerseyPublisher.SubscriberWrapper<T> extends Object implements Flow.Subscriber<T>
Constructor and Description |
---|
SubscriberWrapper(Flow.Subscriber<? super T> subscriber) |
Modifier and Type | Method and Description |
---|---|
Flow.Subscription |
getSubscription()
Get reference to subscriber's
Flow.Subscription . |
Flow.Subscriber<? super T> |
getWrappedSubscriber() |
void |
onComplete()
Method invoked when it is known that no additional
Subscriber method invocations will occur for a Subscription
that is not already terminated by error, after which no
other Subscriber methods are invoked by the Subscription.
|
void |
onError(Throwable throwable)
Method invoked upon an unrecoverable error encountered by a
Publisher or Subscription, after which no other Subscriber
methods are invoked by the Subscription.
|
void |
onNext(T item)
Method invoked with a Subscription's next item.
|
void |
onSubscribe(Flow.Subscription subscription)
Method invoked prior to invoking any other Subscriber
methods for the given Subscription.
|
public SubscriberWrapper(Flow.Subscriber<? super T> subscriber)
public void onSubscribe(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 subscriptionpublic void onNext(T item)
Flow.Subscriber
onNext
in interface Flow.Subscriber<T>
item
- the itempublic void onError(Throwable throwable)
Flow.Subscriber
onError
in interface Flow.Subscriber<T>
throwable
- the exceptionpublic void onComplete()
Flow.Subscriber
onComplete
in interface Flow.Subscriber<T>
public Flow.Subscriber<? super T> getWrappedSubscriber()
public Flow.Subscription getSubscription()
Flow.Subscription
.subscription
Copyright © 2007-2024, Oracle and/or its affiliates. All Rights Reserved. Use is subject to license terms.