Modifier and Type	Class and Description
pack-priv static class	ByteBufMono.ByteBufMonoFuseable
pack-priv static class	ByteBufMono.ReleasingInputStream

Access	Constructor and Description
pack-priv	ByteBufMono(Mono<?> source)

Method Summary

Modifier and Type	Method and Description
public final Mono<byte[]>	Returns: a byte[] inbound `Mono` asByteArray() a byte[] inbound `Mono`.
public final Mono<ByteBuffer>	Returns: a `ByteBuffer` inbound `Mono` asByteBuffer() a `ByteBuffer` inbound `Mono`.
public final Mono<InputStream>	Returns: a `InputStream` inbound `Mono` asInputStream() Convert to an `InputStream` inbound `Mono` Note Auto memory release is disabled.
public final Mono<String>	Returns: a `String` inbound `Mono` asString() a `String` inbound `Mono`.
public final Mono<String>	Returns: a `String` inbound `Mono` asString(Charset the decoding charset charset) a `String` inbound `Mono`.
public static ByteBufMono	Returns: a `ByteBufMono` fromString(Publisher<? extends String> publisher to decorate source) Decorate as `ByteBufMono`.
public static ByteBufMono	Returns: a `ByteBufMono` fromString(Publisher<? extends String> publisher to decorate source, Charset the encoding charset charset, ByteBufAllocator the `ByteBufAllocator` allocator) Decorate as `ByteBufMono`.
pack-priv static ByteBufMono	maybeFuse(Mono<?> source)
public final ByteBufMono	Returns: `ByteBufMono` of retained `ByteBuf` retain() Disable auto memory release on each signal published in order to prevent premature recycling when buffers are accumulated downstream (async).
public void	subscribe(CoreSubscriber<? super ByteBuf> the `Subscriber` interested into the published sequence actual) Implements abstract reactor.core.publisher.Mono.subscribe. Implements reactor.core.CorePublisher.subscribe. An internal `Publisher#subscribe(Subscriber)` that will bypass `Hooks#onLastOperator(Function)` pointcut.

Inherited from reactor.core.publisher.MonoOperator:: scanUnsafe

Constructor Detail

ByteBufMono	back to summary
pack-priv ByteBufMono(Mono<?> source)

Method Detail

asByteArray back to summary

asByteArray	back to summary
public final Mono<byte[]> asByteArray() a byte[] inbound `Mono`. Returns:Mono<byte[]> a byte[] inbound `Mono`

public final Mono<byte[]> asByteArray()

a byte[] inbound Mono.

Returns:Mono<byte[]>: a byte[] inbound Mono

asByteBuffer back to summary

asByteBuffer	back to summary
public final Mono<ByteBuffer> asByteBuffer() a `ByteBuffer` inbound `Mono`. Returns:Mono<ByteBuffer> a `ByteBuffer` inbound `Mono`

public final Mono<ByteBuffer> asByteBuffer()

a ByteBuffer inbound Mono.

Returns:Mono<ByteBuffer>: a ByteBuffer inbound Mono

asInputStream back to summary

asInputStream	back to summary
public final Mono<InputStream> asInputStream() Convert to an `InputStream` inbound `Mono` Note Auto memory release is disabled. The underlying `ByteBuf` will be released only when `InputStream#close()` is invoked. Ensure `InputStream#close()` is invoked for any terminal signal: `complete` \| `error` \| `cancel` Returns:Mono<InputStream> a `InputStream` inbound `Mono`

public final Mono<InputStream> asInputStream()

Convert to an InputStream inbound Mono

Note

Auto memory release is disabled. The underlying ByteBuf will be released only when InputStream#close() is invoked. Ensure InputStream#close() is invoked for any terminal signal: complete | error | cancel

Returns:Mono<InputStream>: a InputStream inbound Mono

asString back to summary

asString	back to summary
public final Mono<String> asString() a `String` inbound `Mono`. Returns:Mono<String> a `String` inbound `Mono`

public final Mono<String> asString()

a String inbound Mono.

Returns:Mono<String>: a String inbound Mono

asString back to summary

asString	back to summary
public final Mono<String> asString(Charset charset) a `String` inbound `Mono`. Parameters charset:Charset the decoding charset Returns:Mono<String> a `String` inbound `Mono`

public final Mono<String> asString(Charset charset)

a String inbound Mono.

Parameters

charset:Charset: the decoding charset

Returns:Mono<String>

a String inbound Mono

fromString back to summary

fromString	back to summary
public static ByteBufMono fromString(Publisher<? extends String> source) Decorate as `ByteBufMono`. Parameters source:Publisher<? extends String> publisher to decorate Returns:ByteBufMono a `ByteBufMono`

public static ByteBufMono fromString(Publisher<? extends String> source)

Decorate as ByteBufMono.

Parameters

source:Publisher<? extends String>: publisher to decorate

Returns:ByteBufMono

a ByteBufMono

fromString back to summary

fromString	back to summary
public static ByteBufMono fromString(Publisher<? extends String> source, Charset charset, ByteBufAllocator allocator) Decorate as `ByteBufMono`. Parameters source:Publisher<? extends String> publisher to decorate charset:Charset the encoding charset allocator:ByteBufAllocator the `ByteBufAllocator` Returns:ByteBufMono a `ByteBufMono`

public static ByteBufMono fromString(Publisher<? extends String> source, Charset charset, ByteBufAllocator allocator)

Decorate as ByteBufMono.

Parameters

source:Publisher<? extends String>: publisher to decorate
charset:Charset: the encoding charset
allocator:ByteBufAllocator: the ByteBufAllocator

Returns:ByteBufMono

a ByteBufMono

maybeFuse	back to summary
pack-priv static ByteBufMono maybeFuse(Mono<?> source)

retain back to summary

retain	back to summary
public final ByteBufMono retain() Disable auto memory release on each signal published in order to prevent premature recycling when buffers are accumulated downstream (async). Returns:ByteBufMono `ByteBufMono` of retained `ByteBuf`

public final ByteBufMono retain()

Disable auto memory release on each signal published in order to prevent premature recycling when buffers are accumulated downstream (async).

Returns:ByteBufMono: ByteBufMono of retained ByteBuf

subscribe back to summary

subscribe	back to summary
public void subscribe(CoreSubscriber<? super ByteBuf> actual) Implements abstract reactor.core.publisher.Mono.subscribe. Implements reactor.core.CorePublisher.subscribe. Doc from reactor.core.publisher.Mono.subscribe. An internal `Publisher#subscribe(Subscriber)` that will bypass `Hooks#onLastOperator(Function)` pointcut. In addition to behave as expected by `Publisher#subscribe(Subscriber)` in a controlled manner, it supports direct subscribe-time `Context` passing. Parameters actual:CoreSubscriber<? super ByteBuf> the `Subscriber` interested into the published sequence Annotations @Override

public void subscribe(CoreSubscriber<? super ByteBuf> actual)

Implements abstract reactor.core.publisher.Mono.subscribe.

Implements reactor.core.CorePublisher.subscribe.

Doc from reactor.core.publisher.Mono.subscribe.

An internal Publisher#subscribe(Subscriber) that will bypass Hooks#onLastOperator(Function) pointcut.

In addition to behave as expected by Publisher#subscribe(Subscriber) in a controlled manner, it supports direct subscribe-time Context passing.

Parameters

actual:CoreSubscriber<? super ByteBuf>: the Subscriber interested into the published sequence

Annotations

@Override

reactor.netty back to summary

pack-priv final Class ByteBufMono.ByteBufMonoFuseable

Class Inheritance

extends ByteBufMono
implements Fuseable

java.lang.Object
reactor.core.publisher.Mono
reactor.core.publisher.MonoOperator
reactor.netty.ByteBufMono
reactor.netty.ByteBufMono.ByteBufMonoFuseable

All Implemented Interfaces

reactor.core.Fuseable

Constructor Summary

Access	Constructor and Description
pack-priv	ByteBufMonoFuseable(Mono<?> source)

Method Summary

Inherited from reactor.netty.ByteBufMono:: asByteArray asByteBuffer asInputStream asString asString fromString fromString maybeFuse retain subscribe

Constructor Detail

ByteBufMonoFuseable	back to summary
pack-priv ByteBufMonoFuseable(Mono<?> source)

reactor.netty back to summary

pack-priv final Class ByteBufMono.ReleasingInputStream

Class Inheritance

extends ByteBufInputStream

java.lang.Object
java.io.InputStream
io.netty.buffer.ByteBufInputStream
reactor.netty.ByteBufMono.ReleasingInputStream

Field Summary

Modifier and Type	Field and Description
pack-priv final ByteBuf	bb
pack-priv static final AtomicIntegerFieldUpdater<ByteBufMono.ReleasingInputStream>	CLOSE
pack-priv volatile int	closed Hides io.netty.buffer.ByteBufInputStream.closed.

Constructor Summary

Access	Constructor and Description
pack-priv	ReleasingInputStream(ByteBuf bb)

Method Summary

Modifier and Type	Method and Description
public void	close() Overrides io.netty.buffer.ByteBufInputStream.close. Implements java.io.Closeable.close. Closes this input stream and releases any system resources associated with the stream.

Field Detail

bb	back to summary
pack-priv final ByteBuf bb

CLOSE	back to summary
pack-priv static final AtomicIntegerFieldUpdater<ByteBufMono.ReleasingInputStream> CLOSE

closed	back to summary
pack-priv volatile int closed Hides io.netty.buffer.ByteBufInputStream.closed.

Constructor Detail

ReleasingInputStream	back to summary
pack-priv ReleasingInputStream(ByteBuf bb)

Method Detail

close	back to summary
public void close() throws IOException Overrides io.netty.buffer.ByteBufInputStream.close. Implements java.io.Closeable.close. Doc from java.io.InputStream.close. Closes this input stream and releases any system resources associated with the stream. Annotations @Override Exceptions IOException: if an I/O error occurs.

back to summary

public void close() throws IOException

Overrides io.netty.buffer.ByteBufInputStream.close.

Implements java.io.Closeable.close.

Doc from java.io.InputStream.close.

Closes this input stream and releases any system resources associated with the stream.

Annotations

@Override

Exceptions

IOException:: if an I/O error occurs.

public Class ByteBufMono

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Constructor Detail

Method Detail

pack-priv final Class ByteBufMono.ByteBufMonoFuseable

Constructor Summary

Method Summary

Constructor Detail

pack-priv final Class ByteBufMono.ReleasingInputStream

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail