Package io.micronaut.reactor.http.client.sse

Class BridgedReactorSseClient

java.lang.Object
io.micronaut.reactor.http.client.sse.BridgedReactorSseClient
All Implemented Interfaces:
io.micronaut.http.client.sse.SseClient, ReactorSseClient, AutoCloseable
@Internal public class BridgedReactorSseClient extends Object implements ReactorSseClient, AutoCloseable
Reactor bridge for the Server Sent events HTTP client.
Since:
2.0.0
Author:
Sergio del Amo

  • Constructor Summary

    Constructors
    Constructor
    Description
    BridgedReactorSseClient(io.micronaut.http.client.sse.SseClient sseClient)
    Default constructor.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
     
    <I> reactor.core.publisher.Flux<io.micronaut.http.sse.Event<io.micronaut.core.io.buffer.ByteBuffer<?>>>
    eventStream(@NonNull io.micronaut.http.HttpRequest<I> request)
     
    <I, B> reactor.core.publisher.Flux<io.micronaut.http.sse.Event<B>>
    eventStream(@NonNull io.micronaut.http.HttpRequest<I> request, @NonNull io.micronaut.core.type.Argument<B> eventType)
     
    <I, B> org.reactivestreams.Publisher<io.micronaut.http.sse.Event<B>>
    eventStream(@NonNull io.micronaut.http.HttpRequest<I> request, @NonNull io.micronaut.core.type.Argument<B> eventType, @NonNull io.micronaut.core.type.Argument<?> errorType)
     
    <I, B> reactor.core.publisher.Flux<io.micronaut.http.sse.Event<B>>
    eventStream(@NonNull io.micronaut.http.HttpRequest<I> request, @NonNull Class<B> eventType)
     
    <B> reactor.core.publisher.Flux<io.micronaut.http.sse.Event<B>>
    eventStream(@NonNull String uri, @NonNull io.micronaut.core.type.Argument<B> eventType)
     
    <B> reactor.core.publisher.Flux<io.micronaut.http.sse.Event<B>>
    eventStream(@NonNull String uri, @NonNull Class<B> eventType)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • BridgedReactorSseClient

      public BridgedReactorSseClient(io.micronaut.http.client.sse.SseClient sseClient)
      Default constructor.
      Parameters:
      sseClient - Server Sent Events HTTP Client

  • Method Details

    • eventStream

      public <I> reactor.core.publisher.Flux<io.micronaut.http.sse.Event<io.micronaut.core.io.buffer.ByteBuffer<?>>> eventStream(@NonNull @NonNull io.micronaut.http.HttpRequest<I> request)
      Specified by:
      eventStream in interface ReactorSseClient
      Specified by:
      eventStream in interface io.micronaut.http.client.sse.SseClient

    • eventStream

      public <I, B> reactor.core.publisher.Flux<io.micronaut.http.sse.Event<B>> eventStream(@NonNull @NonNull io.micronaut.http.HttpRequest<I> request, @NonNull @NonNull io.micronaut.core.type.Argument<B> eventType)
      Specified by:
      eventStream in interface ReactorSseClient
      Specified by:
      eventStream in interface io.micronaut.http.client.sse.SseClient

    • eventStream

      public <I, B> org.reactivestreams.Publisher<io.micronaut.http.sse.Event<B>> eventStream(@NonNull @NonNull io.micronaut.http.HttpRequest<I> request, @NonNull @NonNull io.micronaut.core.type.Argument<B> eventType, @NonNull @NonNull io.micronaut.core.type.Argument<?> errorType)
      Specified by:
      eventStream in interface io.micronaut.http.client.sse.SseClient

    • eventStream

      public <I, B> reactor.core.publisher.Flux<io.micronaut.http.sse.Event<B>> eventStream(@NonNull @NonNull io.micronaut.http.HttpRequest<I> request, @NonNull @NonNull Class<B> eventType)
      Specified by:
      eventStream in interface ReactorSseClient
      Specified by:
      eventStream in interface io.micronaut.http.client.sse.SseClient

    • eventStream

      public <B> reactor.core.publisher.Flux<io.micronaut.http.sse.Event<B>> eventStream(@NonNull @NonNull String uri, @NonNull @NonNull Class<B> eventType)
      Specified by:
      eventStream in interface ReactorSseClient
      Specified by:
      eventStream in interface io.micronaut.http.client.sse.SseClient

    • eventStream

      public <B> reactor.core.publisher.Flux<io.micronaut.http.sse.Event<B>> eventStream(@NonNull @NonNull String uri, @NonNull @NonNull io.micronaut.core.type.Argument<B> eventType)
      Specified by:
      eventStream in interface ReactorSseClient
      Specified by:
      eventStream in interface io.micronaut.http.client.sse.SseClient

    • close

      public void close() throws Exception
      Specified by:
      close in interface AutoCloseable
      Throws:
      Exception