public interface RxSseClient extends SseClient
SseClient
for RxJava 2.x.Modifier and Type | Method and Description |
---|---|
<I> io.reactivex.Flowable<Event<ByteBuffer<?>>> |
eventStream(HttpRequest<I> request)
Perform an HTTP request and receive data as a stream of SSE
Event objects as they become available without blocking. |
<I,B> io.reactivex.Flowable<Event<B>> |
eventStream(HttpRequest<I> request,
Argument<B> eventType)
Perform an HTTP request and receive data as a stream of SSE
Event objects as they become available without blocking. |
default <I,B> io.reactivex.Flowable<Event<B>> |
eventStream(HttpRequest<I> request,
Class<B> eventType)
Perform an HTTP request and receive data as a stream of SSE
Event objects as they become available without blocking. |
default <B> io.reactivex.Flowable<Event<B>> |
eventStream(String uri,
Argument<B> eventType)
Perform an HTTP GET request and receive data as a stream of SSE
Event objects as they become available without blocking. |
default <B> io.reactivex.Flowable<Event<B>> |
eventStream(String uri,
Class<B> eventType)
Perform an HTTP GET request and receive data as a stream of SSE
Event objects as they become available without blocking. |
<I> io.reactivex.Flowable<Event<ByteBuffer<?>>> eventStream(HttpRequest<I> request)
SseClient
Perform an HTTP request and receive data as a stream of SSE Event
objects as they become available without blocking.
The downstream Subscriber
can regulate demand via the subscription
eventStream
in interface SseClient
I
- The request body typerequest
- The HttpRequest
to executePublisher
that emits an Event
with the data represented as a ByteBuffer
<I,B> io.reactivex.Flowable<Event<B>> eventStream(HttpRequest<I> request, Argument<B> eventType)
SseClient
Perform an HTTP request and receive data as a stream of SSE Event
objects as they become available without blocking.
The downstream Subscriber
can regulate demand via the subscription
eventStream
in interface SseClient
I
- The request body typeB
- The event body typerequest
- The HttpRequest
to executeeventType
- The event data typePublisher
that emits an Event
with the data represented by the eventType argumentdefault <I,B> io.reactivex.Flowable<Event<B>> eventStream(HttpRequest<I> request, Class<B> eventType)
SseClient
Perform an HTTP request and receive data as a stream of SSE Event
objects as they become available without blocking.
The downstream Subscriber
can regulate demand via the subscription
eventStream
in interface SseClient
I
- The request body typeB
- The event body typerequest
- The HttpRequest
to executeeventType
- The event data typePublisher
that emits an Event
with the data represented by the eventType argumentdefault <B> io.reactivex.Flowable<Event<B>> eventStream(String uri, Class<B> eventType)
SseClient
Perform an HTTP GET request and receive data as a stream of SSE Event
objects as they become available without blocking.
The downstream Subscriber
can regulate demand via the subscription
eventStream
in interface SseClient
B
- The event body typeuri
- The request URIeventType
- The event data typePublisher
that emits an Event
with the data represented by the eventType argumentdefault <B> io.reactivex.Flowable<Event<B>> eventStream(String uri, Argument<B> eventType)
SseClient
Perform an HTTP GET request and receive data as a stream of SSE Event
objects as they become available without blocking.
The downstream Subscriber
can regulate demand via the subscription
eventStream
in interface SseClient
B
- The event body typeuri
- The request URIeventType
- The event data typePublisher
that emits an Event
with the data represented by the eventType argument