Module io.helidon.common.reactive

Package io.helidon.common.reactive

Class MultiFromOutputStream

java.lang.Object

java.io.OutputStream

io.helidon.common.reactive.MultiFromOutputStream

All Implemented Interfaces:

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

Direct Known Subclasses:

OutputStreamMulti

@Deprecated(since="2.0.0",
            forRemoval=true)
public class MultiFromOutputStream
extends OutputStream
implements Multi<ByteBuffer>

Deprecated, for removal: This API element is subject to removal in a future version.

please use OutputStreamMulti instead

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

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	MultiFromOutputStream()	Deprecated, for removal: This API element is subject to removal in a future version. Create new output stream that Flow.Publisher publishes any data written to it as ByteBuffer events.

Method Summary

Modifier and Type	Method	Description
void	close()	Deprecated, for removal: This API element is subject to removal in a future version.
void	flush()	Deprecated, for removal: This API element is subject to removal in a future version. Send empty buffer as an indication of a user-requested flush.
MultiFromOutputStream	onRequest(BiConsumer<Long,Long> requestCallback)	Deprecated, for removal: This API element is subject to removal in a future version. Callback executed when request signal from downstream arrive.
void	subscribe(Flow.Subscriber<? super ByteBuffer> subscriber)	Deprecated, for removal: This API element is subject to removal in a future version.
void	write(byte[] b)	Deprecated, for removal: This API element is subject to removal in a future version. Writes byte array after possibly publishing internal buffer for single-byte writes.
void	write(byte[] b, int off, int len)	Deprecated, for removal: This API element is subject to removal in a future version. Writes byte array given an offset and length after possibly publishing internal buffer for single-byte writes.
void	write(int b)	Deprecated, for removal: This API element is subject to removal in a future version. Attempts to buffer single-byte reads until buffer is full.

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, forEachCompletionStage, 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 Details

MultiFromOutputStream

protected MultiFromOutputStream()

Deprecated, for removal: This API element is subject to removal in a future version.

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

Method Details

onRequest

public MultiFromOutputStream onRequest(BiConsumer<Long,Long> requestCallback)

Deprecated, for removal: This API element is subject to removal in a future version.

Callback executed when request signal from downstream arrive.

• param n the requested count.
• param demand the current total cumulative requested count, ranges between [0, Long.MAX_VALUE] where the max indicates that this publisher is unbounded.

Parameters:

requestCallback - to be executed

Returns:

this OutputStreamMulti

subscribe

public void subscribe(Flow.Subscriber<? super ByteBuffer> subscriber)

Deprecated, for removal: This API element is subject to removal in a future version.

Specified by:

subscribe in interface Flow.Publisher<ByteBuffer>

write

public void write(byte[] b)
           throws IOException

Deprecated, for removal: This API element is subject to removal in a future version.

Writes byte array after possibly publishing internal buffer for single-byte writes.

Overrides:

write in class OutputStream

Parameters:

b - Byte array.

Throws:

IOException - If error while writing.

write

public void write(byte[] b,
 int off,
 int len)
           throws IOException

Deprecated, for removal: This API element is subject to removal in a future version.

Writes byte array given an offset and length after possibly publishing internal buffer for single-byte writes.

Overrides:

write in class OutputStream

Parameters:

b - Byte array.

Throws:

IOException - If error while writing.

write

public void write(int b)
           throws IOException

Deprecated, for removal: This API element is subject to removal in a future version.

Attempts to buffer single-byte reads until buffer is full.

Specified by:

write in class OutputStream

Parameters:

b - Byte to read.

Throws:

IOException - If error while writing.

close

public void close()
           throws IOException

Deprecated, for removal: This API element is subject to removal in a future version.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class OutputStream

Throws:

IOException

flush

public void flush()
           throws IOException

Deprecated, for removal: This API element is subject to removal in a future version.

Send empty buffer as an indication of a user-requested flush.

Specified by:

flush in interface Flushable

Overrides:

flush in class OutputStream

Throws:

IOException - If error while writing.