Index

A B C D E I J M O P R S T W 
All Classes and Interfaces|All Packages

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>, String) - 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
create(URL) - Static method in interface io.micronaut.rxjava2.http.client.proxy.RxProxyHttpClient
Create a new RxProxyHttpClient.
create(URL) - Static method in interface io.micronaut.rxjava2.http.client.RxHttpClient
Create a new RxHttpClient.
create(URL) - Static method in interface io.micronaut.rxjava2.http.client.RxStreamingHttpClient
Create a new RxStreamingHttpClient.
create(URL) - Static method in interface io.micronaut.rxjava2.http.client.sse.RxSseClient
Create a new RxSseClient.
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.proxy.RxProxyHttpClient
Create a new ProxyHttpClient with the specified configuration.
create(URL, HttpClientConfiguration) - Static method in interface io.micronaut.rxjava2.http.client.RxHttpClient
Create a new RxHttpClient with the specified configuration.
create(URL, HttpClientConfiguration) - Static method in interface io.micronaut.rxjava2.http.client.RxStreamingHttpClient
Create a new RxStreamingHttpClient with the specified configuration.
create(URL, HttpClientConfiguration) - Static method in interface io.micronaut.rxjava2.http.client.sse.RxSseClient
Create a new RxSseClient with the specified configuration.
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, Argument<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
 
exchange(HttpRequest<I>) - Method in interface io.micronaut.rxjava2.http.client.RxHttpClient
 
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>, Class<O>) - 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
 
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(BodyArgumentBinder<Publisher<Object>>) - 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(BodyArgumentBinder<Publisher<Object>>) - 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(MutableConversionService) - Method in class io.micronaut.rxjava2.converters.RxJavaConverterRegistrar
 
retrieve(HttpRequest<I>) - 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>, Argument<O>, Argument<E>) - Method in interface io.micronaut.rxjava2.http.client.RxHttpClient
 
retrieve(HttpRequest<I>, Class<O>) - 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(BodyArgumentBinder<Publisher<Object>>) - 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 
All Classes and Interfaces|All Packages