A B C D E I J M O P R S T W

A

argumentType() - Method in class io.micronaut.rxjava2.server.upload.binders.MaybeBodyBinder

argumentType() - Method in class io.micronaut.rxjava2.server.upload.binders.ObservableBodyBinder

argumentType() - Method in class io.micronaut.rxjava2.server.upload.binders.SingleBodyBinder

B

bind(ArgumentConversionContext<Maybe>, HttpRequest<?>) - Method in class io.micronaut.rxjava2.server.upload.binders.MaybeBodyBinder

bind(ArgumentConversionContext<Observable>, HttpRequest<?>) - Method in class io.micronaut.rxjava2.server.upload.binders.ObservableBodyBinder

bind(ArgumentConversionContext<Single>, HttpRequest<?>) - Method in class io.micronaut.rxjava2.server.upload.binders.SingleBodyBinder

C

connect(Class<T>, MutableHttpRequest<?>) - Method in interface io.micronaut.rxjava2.http.client.websockets.RxWebSocketClient

connect(Class<T>, URI) - Method in interface io.micronaut.rxjava2.http.client.websockets.RxWebSocketClient

connect(Class<T>, Map<String, Object>) - Method in interface io.micronaut.rxjava2.http.client.websockets.RxWebSocketClient

connect(Class<T>, String) - Method in interface io.micronaut.rxjava2.http.client.websockets.RxWebSocketClient

create(URL) - Static method in interface io.micronaut.rxjava2.http.client.proxy.RxProxyHttpClient

Create a new RxProxyHttpClient.

create(URL, HttpClientConfiguration) - Static method in interface io.micronaut.rxjava2.http.client.proxy.RxProxyHttpClient

Create a new ProxyHttpClient with the specified configuration.

create(URL) - Static method in interface io.micronaut.rxjava2.http.client.RxHttpClient

Create a new RxHttpClient.

create(URL, HttpClientConfiguration) - Static method in interface io.micronaut.rxjava2.http.client.RxHttpClient

Create a new RxHttpClient with the specified configuration.

create(URL) - Static method in interface io.micronaut.rxjava2.http.client.RxStreamingHttpClient

Create a new RxStreamingHttpClient.

create(URL, HttpClientConfiguration) - Static method in interface io.micronaut.rxjava2.http.client.RxStreamingHttpClient

Create a new RxStreamingHttpClient with the specified configuration.

create(URL) - Static method in interface io.micronaut.rxjava2.http.client.sse.RxSseClient

Create a new RxSseClient.

create(URL, HttpClientConfiguration) - Static method in interface io.micronaut.rxjava2.http.client.sse.RxSseClient

Create a new RxSseClient with the specified configuration.

create(URL) - Static method in interface io.micronaut.rxjava2.http.client.websockets.RxWebSocketClient

Create a new RxWebSocketClient.

create(URL, HttpClientConfiguration) - Static method in interface io.micronaut.rxjava2.http.client.websockets.RxWebSocketClient

Create a new RxWebSocketClient with the specified configuration.

D

dataStream(HttpRequest<I>) - Method in interface io.micronaut.rxjava2.http.client.RxStreamingHttpClient

E

eventStream(HttpRequest<I>) - Method in interface io.micronaut.rxjava2.http.client.sse.RxSseClient

eventStream(HttpRequest<I>, Argument<B>) - Method in interface io.micronaut.rxjava2.http.client.sse.RxSseClient

eventStream(HttpRequest<I>, Class<B>) - Method in interface io.micronaut.rxjava2.http.client.sse.RxSseClient

eventStream(String, Class<B>) - Method in interface io.micronaut.rxjava2.http.client.sse.RxSseClient

eventStream(String, Argument<B>) - Method in interface io.micronaut.rxjava2.http.client.sse.RxSseClient

exchange(HttpRequest<I>, Argument<O>) - Method in interface io.micronaut.rxjava2.http.client.RxHttpClient

exchange(HttpRequest<I>, Argument<O>, Argument<E>) - Method in interface io.micronaut.rxjava2.http.client.RxHttpClient

exchange(HttpRequest<I>) - Method in interface io.micronaut.rxjava2.http.client.RxHttpClient

exchange(String) - Method in interface io.micronaut.rxjava2.http.client.RxHttpClient

exchange(String, Class<O>) - Method in interface io.micronaut.rxjava2.http.client.RxHttpClient

exchange(HttpRequest<I>, Class<O>) - Method in interface io.micronaut.rxjava2.http.client.RxHttpClient

exchangeStream(HttpRequest<I>) - Method in interface io.micronaut.rxjava2.http.client.RxStreamingHttpClient

I

io.micronaut.rxjava2.converters - package io.micronaut.rxjava2.converters

RxJava converters.

io.micronaut.rxjava2.http.client - package io.micronaut.rxjava2.http.client

RxJava 2 HTTP Client related classes.

io.micronaut.rxjava2.http.client.proxy - package io.micronaut.rxjava2.http.client.proxy

RxJava 2 Proxy HTTP Client related classes.

io.micronaut.rxjava2.http.client.sse - package io.micronaut.rxjava2.http.client.sse

RxJava 2 SSE HTTP Client related classes.

io.micronaut.rxjava2.http.client.websockets - package io.micronaut.rxjava2.http.client.websockets

io.micronaut.rxjava2.server.upload.binders - package io.micronaut.rxjava2.server.upload.binders

J

jsonStream(HttpRequest<I>) - Method in interface io.micronaut.rxjava2.http.client.RxStreamingHttpClient

jsonStream(HttpRequest<I>, Argument<O>) - Method in interface io.micronaut.rxjava2.http.client.RxStreamingHttpClient

jsonStream(HttpRequest<I>, Class<O>) - Method in interface io.micronaut.rxjava2.http.client.RxStreamingHttpClient

M

MaybeBodyBinder - Class in io.micronaut.rxjava2.server.upload.binders

Bindings Body arguments of type Maybe.

MaybeBodyBinder(ConversionService, HttpContentProcessorResolver) - Constructor for class io.micronaut.rxjava2.server.upload.binders.MaybeBodyBinder

O

ObservableBodyBinder - Class in io.micronaut.rxjava2.server.upload.binders

Bindings Body arguments of type Observable.

ObservableBodyBinder(ConversionService, HttpContentProcessorResolver) - Constructor for class io.micronaut.rxjava2.server.upload.binders.ObservableBodyBinder

P

proxy(HttpRequest<?>) - Method in interface io.micronaut.rxjava2.http.client.proxy.RxProxyHttpClient

R

register(ConversionService<?>) - Method in class io.micronaut.rxjava2.converters.RxJavaConverterRegistrar

retrieve(HttpRequest<I>, Argument<O>, Argument<E>) - Method in interface io.micronaut.rxjava2.http.client.RxHttpClient

retrieve(HttpRequest<I>, Argument<O>) - Method in interface io.micronaut.rxjava2.http.client.RxHttpClient

retrieve(HttpRequest<I>, Class<O>) - Method in interface io.micronaut.rxjava2.http.client.RxHttpClient

retrieve(HttpRequest<I>) - Method in interface io.micronaut.rxjava2.http.client.RxHttpClient

retrieve(String) - Method in interface io.micronaut.rxjava2.http.client.RxHttpClient

RxHttpClient - Interface in io.micronaut.rxjava2.http.client

Extended version of HttpClient that exposes an RxJava 2.x specific interface.

RxJavaConverterRegistrar - Class in io.micronaut.rxjava2.converters

Converters for RxJava.

RxJavaConverterRegistrar() - Constructor for class io.micronaut.rxjava2.converters.RxJavaConverterRegistrar

RxProxyHttpClient - Interface in io.micronaut.rxjava2.http.client.proxy

Extended version of ProxyHttpClient for RxJava 2.

RxProxyHttpClientFactory - Class in io.micronaut.rxjava2.http.client.proxy

Factory interface for creating SseClient.

RxProxyHttpClientFactory(ProxyHttpClientRegistry<?>) - Constructor for class io.micronaut.rxjava2.http.client.proxy.RxProxyHttpClientFactory

Default constructor.

RxReactiveClientResultTransformer - Class in io.micronaut.rxjava2.http.client

Adds custom support for Maybe to handle NOT_FOUND results.

RxReactiveClientResultTransformer() - Constructor for class io.micronaut.rxjava2.http.client.RxReactiveClientResultTransformer

RxSseClient - Interface in io.micronaut.rxjava2.http.client.sse

Extended version of SseClient for RxJava 2.x.

RxSseClientFactory - Class in io.micronaut.rxjava2.http.client.sse

Factory interface for creating SseClient.

RxSseClientFactory(SseClientRegistry<?>) - Constructor for class io.micronaut.rxjava2.http.client.sse.RxSseClientFactory

Default constructor.

RxStreamingHttpClient - Interface in io.micronaut.rxjava2.http.client

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

RxStreamingHttpClientFactory - Class in io.micronaut.rxjava2.http.client

Factory interface for creating clients.

RxStreamingHttpClientFactory(StreamingHttpClientRegistry<?>) - Constructor for class io.micronaut.rxjava2.http.client.RxStreamingHttpClientFactory

Default constructor.

RxWebSocketClient - Interface in io.micronaut.rxjava2.http.client.websockets

Specialization of the WebSocketClient interface for RxJava.

RxWebSocketClientFactory - Class in io.micronaut.rxjava2.http.client.websockets

Factory interface for creating RxJava 2 WebSocketClient.

RxWebSocketClientFactory(WebSocketClientRegistry<?>) - Constructor for class io.micronaut.rxjava2.http.client.websockets.RxWebSocketClientFactory

Default constructor.

S

SingleBodyBinder - Class in io.micronaut.rxjava2.server.upload.binders

Bindings Body arguments of type Single.

SingleBodyBinder(ConversionService, HttpContentProcessorResolver) - Constructor for class io.micronaut.rxjava2.server.upload.binders.SingleBodyBinder

sseClient(InjectionPoint<?>, LoadBalancer, HttpClientConfiguration, BeanContext) - Method in class io.micronaut.rxjava2.http.client.proxy.RxProxyHttpClientFactory

Injects a RxProxyHttpClient client at the given injection point.

sseClient(InjectionPoint<?>, LoadBalancer, HttpClientConfiguration, BeanContext) - Method in class io.micronaut.rxjava2.http.client.sse.RxSseClientFactory

Injects a RxSseClient client at the given injection point.

streamingHttpClient(InjectionPoint<?>, LoadBalancer, HttpClientConfiguration, BeanContext) - Method in class io.micronaut.rxjava2.http.client.RxStreamingHttpClientFactory

Injects a RxStreamingHttpClient client at the given injection point.

superTypes() - Method in class io.micronaut.rxjava2.server.upload.binders.MaybeBodyBinder

superTypes() - Method in class io.micronaut.rxjava2.server.upload.binders.ObservableBodyBinder

superTypes() - Method in class io.micronaut.rxjava2.server.upload.binders.SingleBodyBinder

T

transform(Object) - Method in class io.micronaut.rxjava2.http.client.RxReactiveClientResultTransformer

TYPE - Static variable in class io.micronaut.rxjava2.server.upload.binders.MaybeBodyBinder

TYPE - Static variable in class io.micronaut.rxjava2.server.upload.binders.ObservableBodyBinder

TYPE - Static variable in class io.micronaut.rxjava2.server.upload.binders.SingleBodyBinder

W

webSocketClient(InjectionPoint<?>, LoadBalancer, HttpClientConfiguration, BeanContext) - Method in class io.micronaut.rxjava2.http.client.websockets.RxWebSocketClientFactory

Injects a RxWebSocketClient client at the given injection point.

A B C D E I J M O P R S T W