Class SseEventSubscription<T>

Type Parameters:
T - the type of event
All Implemented Interfaces:

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 Details

    • 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
      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