Index
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 typeMaybe
. - 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 typeObservable
. - 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 typeSingle
. - 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.
All Classes and Interfaces|All Packages