io.micronaut.reactor.http.client

Interface ReactorSseClient

All Superinterfaces:

io.micronaut.http.client.sse.SseClient

public interface ReactorSseClient
extends io.micronaut.http.client.sse.SseClient

Reactor variation of the SseClient interface.

Since:

1.0.0

Author:

graemerocher

Method Summary

Modifier and Type	Method and Description
<I> reactor.core.publisher.Flux<io.micronaut.http.sse.Event<io.micronaut.core.io.buffer.ByteBuffer<?>>>	eventStream(io.micronaut.http.HttpRequest<I> request)
<I,B> reactor.core.publisher.Flux<io.micronaut.http.sse.Event<B>>	eventStream(io.micronaut.http.HttpRequest<I> request, io.micronaut.core.type.Argument<B> eventType)
<I,B> reactor.core.publisher.Flux<io.micronaut.http.sse.Event<B>>	eventStream(io.micronaut.http.HttpRequest<I> request, java.lang.Class<B> eventType)
<B> reactor.core.publisher.Flux<io.micronaut.http.sse.Event<B>>	eventStream(java.lang.String uri, io.micronaut.core.type.Argument<B> eventType)
<B> reactor.core.publisher.Flux<io.micronaut.http.sse.Event<B>>	eventStream(java.lang.String uri, java.lang.Class<B> eventType)

Method Detail

eventStream

<I> reactor.core.publisher.Flux<io.micronaut.http.sse.Event<io.micronaut.core.io.buffer.ByteBuffer<?>>> eventStream(io.micronaut.http.HttpRequest<I> request)

Specified by:

eventStream in interface io.micronaut.http.client.sse.SseClient

eventStream

<I,B> reactor.core.publisher.Flux<io.micronaut.http.sse.Event<B>> eventStream(io.micronaut.http.HttpRequest<I> request,
                                                                              io.micronaut.core.type.Argument<B> eventType)

Specified by:

eventStream in interface io.micronaut.http.client.sse.SseClient

eventStream

<I,B> reactor.core.publisher.Flux<io.micronaut.http.sse.Event<B>> eventStream(io.micronaut.http.HttpRequest<I> request,
                                                                              java.lang.Class<B> eventType)

Specified by:

eventStream in interface io.micronaut.http.client.sse.SseClient

eventStream

<B> reactor.core.publisher.Flux<io.micronaut.http.sse.Event<B>> eventStream(java.lang.String uri,
                                                                            java.lang.Class<B> eventType)

Specified by:

eventStream in interface io.micronaut.http.client.sse.SseClient

eventStream

<B> reactor.core.publisher.Flux<io.micronaut.http.sse.Event<B>> eventStream(java.lang.String uri,
                                                                            io.micronaut.core.type.Argument<B> eventType)

Specified by:

eventStream in interface io.micronaut.http.client.sse.SseClient