Package io.micronaut.rxjava3.http.client

Class Rx3HttpClientFactory

java.lang.Object

io.micronaut.rxjava3.http.client.Rx3HttpClientFactory

@Factory
public class Rx3HttpClientFactory
extends Object

Factory class for creating RxJava 3 clients.

Since:

1.0.0

Author:

graemerocher

Constructor Summary

Constructors

Constructor	Description
Rx3HttpClientFactory(io.micronaut.http.client.StreamingHttpClientRegistry<?> clientRegistry)	Default constructor.

Method Summary

Modifier and Type	Method	Description
protected Rx3StreamingHttpClient	streamingHttpClient(@Nullable io.micronaut.inject.InjectionPoint<?> injectionPoint, @Nullable io.micronaut.http.client.LoadBalancer loadBalancer, @Nullable io.micronaut.http.client.HttpClientConfiguration configuration, io.micronaut.context.BeanContext beanContext)	Injects a Rx3StreamingHttpClient client at the given injection point.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Rx3HttpClientFactory

public Rx3HttpClientFactory(io.micronaut.http.client.StreamingHttpClientRegistry<?> clientRegistry)

Default constructor.

Parameters:

clientRegistry - The client registry

Method Details

streamingHttpClient

@Bean
@Secondary
protected Rx3StreamingHttpClient streamingHttpClient(@Nullable
 @Nullable io.micronaut.inject.InjectionPoint<?> injectionPoint,
 @Parameter @Nullable
 @Nullable io.micronaut.http.client.LoadBalancer loadBalancer,
 @Parameter @Nullable
 @Nullable io.micronaut.http.client.HttpClientConfiguration configuration,
 io.micronaut.context.BeanContext beanContext)

Injects a Rx3StreamingHttpClient client at the given injection point.

Parameters:

injectionPoint - The injection point

loadBalancer - The load balancer to use (Optional)

configuration - The configuration (Optional)

beanContext - The bean context to use

Returns:

The Streaming HTTP Client