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 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