io.micronaut.rxjava3.http.client.sse

Class BridgedRx3SseClient

java.lang.Object

io.micronaut.rxjava3.http.client.sse.BridgedRx3SseClient

All Implemented Interfaces:

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

@Internal
public class BridgedRx3SseClient
extends java.lang.Object
implements Rx3SseClient, java.lang.AutoCloseable

RxJava 2 bridge for the Server side events HTTP client.

Since:

3.0.0

Author:

Sergio del Amo

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	close()
<I> io.reactivex.rxjava3.core.Flowable<io.micronaut.http.sse.Event<io.micronaut.core.io.buffer.ByteBuffer<?>>>	eventStream(io.micronaut.http.HttpRequest<I> request)
<I,B> io.reactivex.rxjava3.core.Flowable<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> io.reactivex.rxjava3.core.Flowable<io.micronaut.http.sse.Event<B>>	eventStream(io.micronaut.http.HttpRequest<I> request, java.lang.Class<B> eventType)
<B> io.reactivex.rxjava3.core.Flowable<io.micronaut.http.sse.Event<B>>	eventStream(java.lang.String uri, io.micronaut.core.type.Argument<B> eventType)
<B> io.reactivex.rxjava3.core.Flowable<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.rxjava3.http.client.Rx3SseClient

create, create

Constructor Detail

BridgedRx3SseClient

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

Default constructor.

Parameters:

sseClient - Server Sent Events HTTP Client

Method Detail

eventStream

public <I> io.reactivex.rxjava3.core.Flowable<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 Rx3SseClient

eventStream

public <I,B> io.reactivex.rxjava3.core.Flowable<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 Rx3SseClient

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> io.reactivex.rxjava3.core.Flowable<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 Rx3SseClient

eventStream

public <B> io.reactivex.rxjava3.core.Flowable<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 Rx3SseClient

eventStream

public <B> io.reactivex.rxjava3.core.Flowable<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 Rx3SseClient

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.Exception