Class PublisherAsBlocking

java.lang.Object
io.micronaut.http.body.stream.PublisherAsBlocking
All Implemented Interfaces:
Closeable, AutoCloseable, Subscriber<ReadBuffer>

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