public interface SseClient
| Modifier and Type | Method and Description |
|---|---|
static SseClient |
create(URL url)
Create a new
SseClient. |
static SseClient |
create(URL url,
HttpClientConfiguration configuration)
Create a new
SseClient with the specified configuration. |
<I> Publisher<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> Publisher<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. |
<I,B> Publisher<Event<B>> |
eventStream(HttpRequest<I> request,
Argument<B> eventType,
Argument<?> errorType)
Perform an HTTP request and receive data as a stream of SSE
Event objects as they become available without blocking. |
default <I,B> Publisher<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> Publisher<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> Publisher<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> Publisher<Event<ByteBuffer<?>>> eventStream(@NonNull HttpRequest<I> request)
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
I - The request body typerequest - The HttpRequest to executePublisher that emits an Event with the data represented as a ByteBuffer<I,B> Publisher<Event<B>> eventStream(@NonNull HttpRequest<I> request, @NonNull Argument<B> eventType)
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
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 argument<I,B> Publisher<Event<B>> eventStream(@NonNull HttpRequest<I> request, @NonNull Argument<B> eventType, @NonNull Argument<?> errorType)
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
I - The request body typeB - The event body typerequest - The HttpRequest to executeeventType - The event data typeerrorType - The type that the response body should be coerced into if the server responds with an errorPublisher that emits an Event with the data represented by the eventType argumentdefault <I,B> Publisher<Event<B>> eventStream(@NonNull HttpRequest<I> request, @NonNull Class<B> eventType)
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
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> Publisher<Event<B>> eventStream(@NonNull String uri, @NonNull Class<B> eventType)
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
default <B> Publisher<Event<B>> eventStream(@NonNull String uri, @NonNull Argument<B> eventType)
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
static SseClient create(@Nullable URL url)
SseClient.
Note that this method should only be used outside of the context of a Micronaut application.
The returned SseClient is not subject to dependency injection.
The creator is responsible for closing the client to avoid leaking connections.
Within a Micronaut application use Inject to inject a client instead.url - The base URLstatic SseClient create(@Nullable URL url, @NonNull HttpClientConfiguration configuration)
SseClient with the specified configuration. Note that this method should only be used
outside of the context of an application. Within Micronaut use Inject to inject a client insteadurl - The base URLconfiguration - the client configuration