io.micronaut.rxjava3.http.client

Interface Rx3StreamingHttpClient

All Superinterfaces:

java.lang.AutoCloseable, java.io.Closeable, io.micronaut.http.client.HttpClient, io.micronaut.context.LifeCycle<io.micronaut.http.client.HttpClient>, io.micronaut.http.client.StreamingHttpClient

public interface Rx3StreamingHttpClient
extends io.micronaut.http.client.StreamingHttpClient

RxJava 3 variation of the StreamingHttpClient interface.

Since:

1.0.0

Author:

graemerocher

Field Summary

Fields inherited from interface io.micronaut.http.client.HttpClient

DEFAULT_ERROR_TYPE

Method Summary

Modifier and Type	Method and Description
<I> io.reactivex.rxjava3.core.Flowable<io.micronaut.core.io.buffer.ByteBuffer<?>>	dataStream(io.micronaut.http.HttpRequest<I> request)
<I> io.reactivex.rxjava3.core.Flowable<io.micronaut.http.HttpResponse<io.micronaut.core.io.buffer.ByteBuffer<?>>>	exchangeStream(io.micronaut.http.HttpRequest<I> request)
<I> io.reactivex.rxjava3.core.Flowable<java.util.Map<java.lang.String,java.lang.Object>>	jsonStream(io.micronaut.http.HttpRequest<I> request)
<I,O> io.reactivex.rxjava3.core.Flowable<O>	jsonStream(io.micronaut.http.HttpRequest<I> request, io.micronaut.core.type.Argument<O> type)
<I,O> io.reactivex.rxjava3.core.Flowable<O>	jsonStream(io.micronaut.http.HttpRequest<I> request, java.lang.Class<O> type)

Methods inherited from interface io.micronaut.http.client.HttpClient

create, exchange, exchange, exchange, exchange, exchange, exchange, refresh, retrieve, retrieve, retrieve, retrieve, retrieve, toBlocking

Methods inherited from interface io.micronaut.context.LifeCycle

close, isRunning, start, stop

Method Detail

dataStream

<I> io.reactivex.rxjava3.core.Flowable<io.micronaut.core.io.buffer.ByteBuffer<?>> dataStream(io.micronaut.http.HttpRequest<I> request)

Specified by:

dataStream in interface io.micronaut.http.client.StreamingHttpClient

exchangeStream

<I> io.reactivex.rxjava3.core.Flowable<io.micronaut.http.HttpResponse<io.micronaut.core.io.buffer.ByteBuffer<?>>> exchangeStream(io.micronaut.http.HttpRequest<I> request)

Specified by:

exchangeStream in interface io.micronaut.http.client.StreamingHttpClient

jsonStream

<I> io.reactivex.rxjava3.core.Flowable<java.util.Map<java.lang.String,java.lang.Object>> jsonStream(io.micronaut.http.HttpRequest<I> request)

Specified by:

jsonStream in interface io.micronaut.http.client.StreamingHttpClient

jsonStream

<I,O> io.reactivex.rxjava3.core.Flowable<O> jsonStream(io.micronaut.http.HttpRequest<I> request,
                                                       io.micronaut.core.type.Argument<O> type)

Specified by:

jsonStream in interface io.micronaut.http.client.StreamingHttpClient

jsonStream

<I,O> io.reactivex.rxjava3.core.Flowable<O> jsonStream(io.micronaut.http.HttpRequest<I> request,
                                                       java.lang.Class<O> type)

Specified by:

jsonStream in interface io.micronaut.http.client.StreamingHttpClient