Package io.micronaut.http.netty.reactive

Interface HotObservable<T>

Type Parameters:
T - The type of data being published
All Superinterfaces:
Publisher<T>
All Known Subinterfaces:
StreamedHttpRequest
All Known Implementing Classes:
DefaultStreamedHttpRequest, DelegateStreamedHttpRequest, HandlerPublisher
public interface HotObservable<T> extends Publisher<T>
A contract for a publisher that buffers data to allow for the release of that data if there will not be a subscriber.
Since:
1.2.1
Author:
James Kleeh

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    closeIfNoSubscriber()
    Releases buffered data if there is no subscriber.

    Methods inherited from interface org.reactivestreams.Publisher

    subscribe

  • Method Details

    • closeIfNoSubscriber

      void closeIfNoSubscriber()
      Releases buffered data if there is no subscriber.