Module io.helidon.common.reactive

Package io.helidon.common.reactive

Class OutputStreamMulti

java.lang.Object

java.io.OutputStream

io.helidon.common.reactive.MultiFromOutputStream

io.helidon.common.reactive.OutputStreamMulti

All Implemented Interfaces:

Multi<ByteBuffer>, Subscribable<ByteBuffer>, Closeable, Flushable, AutoCloseable, Flow.Publisher<ByteBuffer>

public class OutputStreamMulti
extends MultiFromOutputStream

Output stream that Flow.Publisher publishes any data written to it as ByteBuffer events.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	OutputStreamMulti()	Create new output stream that Flow.Publisher publishes any data written to it as ByteBuffer events.

Method Summary

Methods inherited from class io.helidon.common.reactive.MultiFromOutputStream

close, flush, onRequest, subscribe, write, write, write

Methods inherited from class java.io.OutputStream

nullOutputStream

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.helidon.common.reactive.Multi

collect, collect, collectList, collectStream, compose, defaultIfEmpty, defaultIfEmpty, distinct, dropWhile, filter, first, flatMap, flatMap, flatMapCompletionStage, flatMapIterable, flatMapIterable, flatMapOptional, forEach, ifEmpty, ignoreElements, limit, log, log, log, log, map, observeOn, observeOn, onCancel, onComplete, onCompleteResume, onCompleteResumeWith, onError, onErrorResume, onErrorResumeWith, onTerminate, peek, reduce, reduce, retry, retry, retryWhen, skip, switchIfEmpty, takeUntil, takeWhile, timeout, timeout, to

Methods inherited from interface io.helidon.common.reactive.Subscribable

subscribe, subscribe, subscribe, subscribe

Constructor Detail

OutputStreamMulti

protected OutputStreamMulti()

Create new output stream that Flow.Publisher publishes any data written to it as ByteBuffer events.