org.glassfish.jersey.microprofile.restclient

Class SseEventSubscription<T>

java.lang.Object

org.glassfish.jersey.microprofile.restclient.SseEventSubscription<T>

Type Parameters:

T - the type of event

All Implemented Interfaces:

org.reactivestreams.Subscription

public class SseEventSubscription<T>
extends Object
implements org.reactivestreams.Subscription

A SseEventSubscription represents a one-to-one life-cycle of a Subscriber subscribing to a SseEventPublisher.

Method Summary

Modifier and Type	Method and Description
void	cancel() Request the SseEventPublisher to stop sending data and clean up resources.
void	request(long n) No events will be sent by a SseEventPublisher until demand is signaled via request(long) method.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

request

public void request(long n)

No events will be sent by a SseEventPublisher until demand is signaled via request(long) method.

Specified by:

request in interface org.reactivestreams.Subscription

Parameters:

n - the strictly positive number of elements to requests to the SseEventPublisher

cancel

public void cancel()

Request the SseEventPublisher to stop sending data and clean up resources. Data may still be sent to meet previously signaled demand after calling cancel.

Specified by:

cancel in interface org.reactivestreams.Subscription