Class PublisherAsBlocking<T>

java.lang.Object
io.micronaut.http.netty.PublisherAsBlocking<T>
Type Parameters:
T - Stream type
All Implemented Interfaces:
Closeable, AutoCloseable, Subscriber<T>

@Internal public final class PublisherAsBlocking<T> extends Object implements Subscriber<T>, Closeable
A subscriber that allows blocking reads from a publisher. Handles resource cleanup properly.
Since:
4.2.0
Author:
Jonas Konrad