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
,DefaultStreamedHttpResponse
,DelegateStreamedHttpRequest
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 TypeMethodDescriptionvoid
Releases buffered data if there is no subscriber.
-
Method Details
-
closeIfNoSubscriber
void closeIfNoSubscriber()Releases buffered data if there is no subscriber.
-