Class SseEventPublisher

All Implemented Interfaces:
Closeable, AutoCloseable, org.reactivestreams.Publisher<InboundEvent>

public class SseEventPublisher extends EventInput implements org.reactivestreams.Publisher<InboundEvent>
  • Method Details

    • subscribe

      public void subscribe(org.reactivestreams.Subscriber subscriber)
      Request SseEventPublisher to start streaming data. Each SseEventSubscription will work for only a single Subscriber. If the SseEventPublisher rejects the subscription attempt or otherwise fails it will signal the error via Subscriber.onError(Throwable).
      Specified by:
      subscribe in interface org.reactivestreams.Publisher<InboundEvent>
      Parameters:
      subscriber - the Subscriber that will consume signals from the SseEventPublisher