org.glassfish.jersey.microprofile.restclient

Class SseEventPublisher

java.lang.Object

javax.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 and 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 javax.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 Detail

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