Package io.micronaut.rxjava3.http.client.sse

Class BridgedRx3SseClient

java.lang.Object
io.micronaut.rxjava3.http.client.sse.BridgedRx3SseClient
All Implemented Interfaces:
io.micronaut.http.client.sse.SseClient, Rx3SseClient, AutoCloseable
@Internal public class BridgedRx3SseClient extends Object implements Rx3SseClient, AutoCloseable
RxJava 2 bridge for the Server side events HTTP client.
Since:
3.0.0
Author:
Sergio del Amo

  • Constructor Summary

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

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
     
    <I> io.reactivex.rxjava3.core.Flowable<io.micronaut.http.sse.Event<io.micronaut.core.io.buffer.ByteBuffer<?>>>
    eventStream(@NonNull io.micronaut.http.HttpRequest<I> request)
     
    <I, B> io.reactivex.rxjava3.core.Flowable<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> io.reactivex.rxjava3.core.Flowable<io.micronaut.http.sse.Event<B>>
    eventStream(@NonNull io.micronaut.http.HttpRequest<I> request, @NonNull Class<B> eventType)
     
    <B> io.reactivex.rxjava3.core.Flowable<io.micronaut.http.sse.Event<B>>
    eventStream(@NonNull String uri, @NonNull io.micronaut.core.type.Argument<B> eventType)
     
    <B> io.reactivex.rxjava3.core.Flowable<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

    • BridgedRx3SseClient

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

  • Method Details

    • eventStream

      public <I> io.reactivex.rxjava3.core.Flowable<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 Rx3SseClient
      Specified by:
      eventStream in interface io.micronaut.http.client.sse.SseClient

    • eventStream

      public <I, B> io.reactivex.rxjava3.core.Flowable<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 Rx3SseClient
      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> io.reactivex.rxjava3.core.Flowable<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 Rx3SseClient
      Specified by:
      eventStream in interface io.micronaut.http.client.sse.SseClient

    • eventStream

      public <B> io.reactivex.rxjava3.core.Flowable<io.micronaut.http.sse.Event<B>> eventStream(@NonNull @NonNull String uri, @NonNull @NonNull Class<B> eventType)
      Specified by:
      eventStream in interface Rx3SseClient
      Specified by:
      eventStream in interface io.micronaut.http.client.sse.SseClient

    • eventStream

      public <B> io.reactivex.rxjava3.core.Flowable<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 Rx3SseClient
      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