Package org.glassfish.jersey.microprofile.restclient

Class SseEventPublisher

java.lang.Object

jakarta.ws.rs.core.GenericType<T>

org.glassfish.jersey.client.ChunkedInput<InboundEvent>

org.glassfish.jersey.media.sse.EventInput

org.glassfish.jersey.microprofile.restclient.SseEventPublisher

All Implemented Interfaces:

Closeable, AutoCloseable, org.reactivestreams.Publisher<InboundEvent>

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

Method Summary

Modifier and Type	Method	Description
void	subscribe(org.reactivestreams.Subscriber subscriber)	Request SseEventPublisher to start streaming data.

Methods inherited from class org.glassfish.jersey.client.ChunkedInput

close, createMultiParser, createParser, createParser, getChunkType, getParser, isClosed, read, setChunkType, setChunkType, setParser

Methods inherited from class jakarta.ws.rs.core.GenericType

equals, forInstance, getRawType, getType, hashCode, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

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