public class SseEventPublisher extends EventInput implements org.reactivestreams.Publisher<InboundEvent>
Modifier and Type | Method and Description |
---|---|
void |
subscribe(org.reactivestreams.Subscriber subscriber)
Request
SseEventPublisher to start streaming data. |
close, createMultiParser, createParser, createParser, getChunkType, getParser, isClosed, read, setChunkType, setChunkType, setParser
equals, forInstance, getRawType, getType, hashCode, toString
public void subscribe(org.reactivestreams.Subscriber subscriber)
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)
.subscribe
in interface org.reactivestreams.Publisher<InboundEvent>
subscriber
- the Subscriber
that will consume signals from
the SseEventPublisher
Copyright © 2007-2024, Oracle and/or its affiliates. All Rights Reserved. Use is subject to license terms.