io.micronaut.reactor.http.client.sse

Class BridgedReactorSseClient

java.lang.Object

io.micronaut.reactor.http.client.sse.BridgedReactorSseClient

All Implemented Interfaces:

io.micronaut.http.client.sse.SseClient, ReactorSseClient, java.lang.AutoCloseable

@Internal
public class BridgedReactorSseClient
extends java.lang.Object
implements ReactorSseClient, java.lang.AutoCloseable

Reactor bridge for the Server Sent events HTTP client.

Since:

2.0.0

Author:

Sergio del Amo

Constructor Summary

Constructors

Constructor and Description
BridgedReactorSseClient(io.micronaut.http.client.sse.SseClient sseClient) Default constructor.

Method Summary

Modifier and Type	Method and Description
void	close()
<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> org.reactivestreams.Publisher<io.micronaut.http.sse.Event<B>>	eventStream(io.micronaut.http.HttpRequest<I> request, io.micronaut.core.type.Argument<B> eventType, io.micronaut.core.type.Argument<?> errorType)
<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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.micronaut.reactor.http.client.ReactorSseClient

create, create

Constructor Detail

BridgedReactorSseClient

public BridgedReactorSseClient(io.micronaut.http.client.sse.SseClient sseClient)

Default constructor.

Parameters:

sseClient - Server Sent Events HTTP Client

Method Detail

eventStream

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

Specified by:

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

Specified by:

eventStream in interface ReactorSseClient

eventStream

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

Specified by:

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

Specified by:

eventStream in interface ReactorSseClient

eventStream

public <I,B> org.reactivestreams.Publisher<io.micronaut.http.sse.Event<B>> eventStream(@NonNull
                                                                                       io.micronaut.http.HttpRequest<I> request,
                                                                                       @NonNull
                                                                                       io.micronaut.core.type.Argument<B> eventType,
                                                                                       @NonNull
                                                                                       io.micronaut.core.type.Argument<?> errorType)

Specified by:

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

eventStream

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

Specified by:

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

Specified by:

eventStream in interface ReactorSseClient

eventStream

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

Specified by:

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

Specified by:

eventStream in interface ReactorSseClient

eventStream

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

Specified by:

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

Specified by:

eventStream in interface ReactorSseClient

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.Exception