io.micronaut.rxjava3.http.client

Interface Rx3SseClient

All Superinterfaces:

io.micronaut.http.client.sse.SseClient

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

RxJava 3 variation of the SseClient interface.

Since:

1.0.0

Author:

graemerocher

Method Summary

Modifier and Type	Method and Description
<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> 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)

Method Detail

eventStream

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

Specified by:

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

eventStream

<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)

Specified by:

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

eventStream

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