io.micronaut.http.netty.reactive

Interface HotObservable<T>

Type Parameters:

T - The type of data being published

All Superinterfaces:

org.reactivestreams.Publisher<T>

All Known Implementing Classes:

HandlerPublisher

public interface HotObservable<T>
extends org.reactivestreams.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 and Description
void	closeIfNoSubscriber() Releases buffered data if there is no subscriber.

Methods inherited from interface org.reactivestreams.Publisher

subscribe

Method Detail

closeIfNoSubscriber

void closeIfNoSubscriber()

Releases buffered data if there is no subscriber.