public class SseEventSuscriber<T> extends Object implements Flow.Subscriber<T>
Constructor and Description |
---|
SseEventSuscriber(org.reactivestreams.Subscriber<T> subscriber) |
Modifier and Type | Method and Description |
---|---|
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 t)
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 flowsubscription)
Method invoked prior to invoking any other Subscriber
methods for the given Subscription.
|
public SseEventSuscriber(org.reactivestreams.Subscriber<T> subscriber)
public void onSubscribe(Flow.Subscription flowsubscription)
Flow.Subscriber
Typically, implementations of this method invoke subscription.request
to enable receiving items.
onSubscribe
in interface Flow.Subscriber<T>
flowsubscription
- a new subscriptionpublic void onNext(T item)
Flow.Subscriber
onNext
in interface Flow.Subscriber<T>
item
- the itempublic void onError(Throwable t)
Flow.Subscriber
onError
in interface Flow.Subscriber<T>
t
- the exceptionpublic void onComplete()
Flow.Subscriber
onComplete
in interface Flow.Subscriber<T>
Copyright © 2007-2024, Oracle and/or its affiliates. All Rights Reserved. Use is subject to license terms.