Core functionality for the Reactor Netty library 2.0.0-M3 · reactor.netty5.BufferMono

Modifier and Type	Class and Description
pack-priv static class	BufferMono.BufferMonoFuseable

Access	Constructor and Description
pack-priv	BufferMono(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 The underlying `Buffer` will be released only when `InputStream#close()` is invoked.
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 BufferMono	Returns: a `BufferMono` fromString(Publisher<? extends String> publisher to decorate source) Decorate as `BufferMono`
public static BufferMono	Returns: a `BufferMono` fromString(Publisher<? extends String> publisher to decorate source, Charset the encoding charset charset, BufferAllocator the `BufferAllocator` allocator) Decorate as `BufferMono`
pack-priv static BufferMono	maybeFuse(Mono<?> source)
public void	subscribe(CoreSubscriber<? super Buffer> 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.
public final Mono<Buffer>	Returns: `Mono` of split `Buffer`s transferOwnership() Returns `Mono` of split `Buffer`s.

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

BufferMono	back to summary
pack-priv BufferMono(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 The underlying `Buffer` 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

The underlying Buffer 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 BufferMono fromString(Publisher<? extends String> source) Decorate as `BufferMono` Parameters source:Publisher<? extends String> publisher to decorate Returns:BufferMono a `BufferMono`

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

Decorate as BufferMono

Parameters

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

Returns:BufferMono

a BufferMono

fromString back to summary

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

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

Decorate as BufferMono

Parameters

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

Returns:BufferMono

a BufferMono

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

subscribe back to summary

subscribe	back to summary
public void subscribe(CoreSubscriber<? super Buffer> 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 Buffer> the `Subscriber` interested into the published sequence Annotations @Override

public void subscribe(CoreSubscriber<? super Buffer> 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 Buffer>: the Subscriber interested into the published sequence

Annotations

@Override

transferOwnership back to summary

transferOwnership	back to summary
public final Mono<Buffer> transferOwnership() Returns `Mono` of split `Buffer`s. This transfers the ownership to the recipient. The caller of this method should ensure the `Buffer`s are closed. Returns:Mono<Buffer> `Mono` of split `Buffer`s

public final Mono<Buffer> transferOwnership()

Returns Mono of split Buffers. This transfers the ownership to the recipient. The caller of this method should ensure the Buffers are closed.

Returns:Mono<Buffer>: Mono of split Buffers

public Class BufferMono

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Constructor Detail

Method Detail

pack-priv final Class BufferMono.BufferMonoFuseable

Constructor Summary

Method Summary

Constructor Detail