Class RxSseClientFactory
java.lang.Object
io.micronaut.rxjava3.http.client.sse.RxSseClientFactory
Factory interface for creating
SseClient
.- Since:
- 2.0.0
- Author:
- Sergio del Amo
-
Constructor Summary
ConstructorDescriptionRxSseClientFactory
(io.micronaut.http.client.sse.SseClientRegistry<?> clientRegistry) Default constructor. -
Method Summary
Modifier and TypeMethodDescriptionprotected Rx3SseClient
sseClient
(@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 aRx3SseClient
client at the given injection point.
-
Constructor Details
-
RxSseClientFactory
public RxSseClientFactory(io.micronaut.http.client.sse.SseClientRegistry<?> clientRegistry) Default constructor.- Parameters:
clientRegistry
- The client registry
-
-
Method Details
-
sseClient
@Bean @Secondary protected Rx3SseClient sseClient(@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 aRx3SseClient
client at the given injection point.- Parameters:
injectionPoint
- The injection pointloadBalancer
- The load balancer to use (Optional)configuration
- The configuration (Optional)beanContext
- The bean context to use- Returns:
- The SSE HTTP Client
-