io.micronaut.rxjava2.http.client

Interface RxStreamingHttpClient

All Superinterfaces:

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

public interface RxStreamingHttpClient
extends io.micronaut.http.client.StreamingHttpClient, RxHttpClient

Extended version of StreamingHttpClient that exposes an RxJava 2.x interface.

Since:

1.0

Author:

Graeme Rocher

Field Summary

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

DEFAULT_ERROR_TYPE

Method Summary

Modifier and Type	Method and Description
static RxStreamingHttpClient	create(java.net.URL url) Create a new RxStreamingHttpClient.
static RxStreamingHttpClient	create(java.net.URL url, io.micronaut.http.client.HttpClientConfiguration configuration) Create a new RxStreamingHttpClient with the specified configuration.
<I> io.reactivex.Flowable<io.micronaut.core.io.buffer.ByteBuffer<?>>	dataStream(io.micronaut.http.HttpRequest<I> request)
<I> io.reactivex.Flowable<io.micronaut.http.HttpResponse<io.micronaut.core.io.buffer.ByteBuffer<?>>>	exchangeStream(io.micronaut.http.HttpRequest<I> request)
<I> org.reactivestreams.Publisher<java.util.Map<java.lang.String,java.lang.Object>>	jsonStream(io.micronaut.http.HttpRequest<I> request)
<I,O> io.reactivex.Flowable<O>	jsonStream(io.micronaut.http.HttpRequest<I> request, io.micronaut.core.type.Argument<O> type)
default <I,O> io.reactivex.Flowable<O>	jsonStream(io.micronaut.http.HttpRequest<I> request, java.lang.Class<O> type)

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

dataStream, exchangeStream, jsonStream

Methods inherited from interface io.micronaut.rxjava2.http.client.RxHttpClient

exchange, exchange, exchange, exchange, exchange, exchange, retrieve, retrieve, retrieve, retrieve, retrieve

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

refresh, toBlocking

Methods inherited from interface io.micronaut.context.LifeCycle

close, isRunning, start, stop

Method Detail

dataStream

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

Specified by:

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

exchangeStream

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

Specified by:

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

jsonStream

<I> org.reactivestreams.Publisher<java.util.Map<java.lang.String,java.lang.Object>> jsonStream(@NonNull
                                                                                               io.micronaut.http.HttpRequest<I> request)

Specified by:

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

jsonStream

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

Specified by:

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

jsonStream

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

Specified by:

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

create

static RxStreamingHttpClient create(@Nullable
                                    java.net.URL url)

Create a new RxStreamingHttpClient. Note that this method should only be used outside of the context of a Micronaut application. The returned RxStreamingHttpClient is not subject to dependency injection. The creator is responsible for closing the client to avoid leaking connections. Within a Micronaut application use Inject to inject a client instead.

Specified by:

create in interface io.micronaut.http.client.HttpClient

Specified by:

create in interface RxHttpClient

Specified by:

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

Parameters:

url - The base URL

Returns:

The client

Since:

1.1.0

create

static RxStreamingHttpClient create(@Nullable
                                    java.net.URL url,
                                    @NonNull
                                    io.micronaut.http.client.HttpClientConfiguration configuration)

Create a new RxStreamingHttpClient with the specified configuration. Note that this method should only be used outside of the context of an application. Within Micronaut use Inject to inject a client instead

Specified by:

create in interface io.micronaut.http.client.HttpClient

Specified by:

create in interface RxHttpClient

Specified by:

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

Parameters:

url - The base URL

configuration - the client configuration

Returns:

The client

Since:

1.1.0