Package reactor.netty

Class ByteBufMono

java.lang.Object

reactor.core.publisher.Mono<O>

reactor.core.publisher.MonoOperator<ByteBuf,ByteBuf>

reactor.netty.ByteBufMono

All Implemented Interfaces:

Publisher<ByteBuf>, CorePublisher<ByteBuf>, Scannable

public class ByteBufMono
extends MonoOperator<ByteBuf,ByteBuf>

A decorating Mono NettyInbound with various ByteBuf related operations.

Author:

Stephane Maldini

Nested Class Summary

Nested classes/interfaces inherited from interface reactor.core.Scannable

Scannable.Attr<T extends Object>

Field Summary

Fields inherited from class reactor.core.publisher.MonoOperator

source

Fields inherited from interface reactor.core.Scannable

OPERATOR_NAME_UNRELATED_WORDS_PATTERN

Method Summary

Modifier and Type	Method	Description
final Mono<byte[]>	asByteArray()	a byte[] inbound Mono.
final Mono<ByteBuffer>	asByteBuffer()	a ByteBuffer inbound Mono.
final Mono<InputStream>	asInputStream()	Convert to an InputStream inbound Mono
final Mono<String>	asString()	a String inbound Mono.
final Mono<String>	asString(Charset charset)	a String inbound Mono.
static ByteBufMono	fromString(Publisher<? extends String> source)	Decorate as ByteBufMono.
static ByteBufMono	fromString(Publisher<? extends String> source, Charset charset, ByteBufAllocator allocator)	Decorate as ByteBufMono.
final ByteBufMono	retain()	Disable auto memory release on each signal published in order to prevent premature recycling when buffers are accumulated downstream (async).
void	subscribe(CoreSubscriber<? super ByteBuf> actual)

Methods inherited from class reactor.core.publisher.MonoOperator

scanUnsafe

Methods inherited from class reactor.core.publisher.Mono

and, as, block, block, blockOptional, blockOptional, cache, cache, cache, cache, cache, cacheInvalidateIf, cacheInvalidateWhen, cacheInvalidateWhen, cancelOn, cast, checkpoint, checkpoint, checkpoint, concatWith, contextCapture, contextWrite, contextWrite, create, defaultIfEmpty, defer, deferContextual, delay, delay, delayElement, delayElement, delaySubscription, delaySubscription, delaySubscription, delayUntil, dematerialize, doAfterTerminate, doFinally, doFirst, doOnCancel, doOnDiscard, doOnEach, doOnError, doOnError, doOnError, doOnNext, doOnRequest, doOnSubscribe, doOnSuccess, doOnTerminate, elapsed, elapsed, empty, error, error, expand, expand, expandDeep, expandDeep, filter, filterWhen, first, first, firstWithSignal, firstWithSignal, firstWithValue, firstWithValue, flatMap, flatMapIterable, flatMapMany, flatMapMany, flux, from, fromCallable, fromCompletionStage, fromCompletionStage, fromDirect, fromFuture, fromFuture, fromFuture, fromFuture, fromRunnable, fromSupplier, handle, hasElement, hide, ignoreElement, ignoreElements, just, justOrEmpty, justOrEmpty, log, log, log, log, log, log, map, mapNotNull, materialize, mergeWith, metrics, name, never, ofType, onAssembly, onErrorComplete, onErrorComplete, onErrorComplete, onErrorContinue, onErrorContinue, onErrorContinue, onErrorMap, onErrorMap, onErrorMap, onErrorResume, onErrorResume, onErrorResume, onErrorReturn, onErrorReturn, onErrorReturn, onErrorStop, onTerminateDetach, or, publish, publishOn, repeat, repeat, repeat, repeat, repeatWhen, repeatWhenEmpty, repeatWhenEmpty, retry, retry, retryWhen, sequenceEqual, sequenceEqual, sequenceEqual, share, single, singleOptional, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeWith, switchIfEmpty, tag, take, take, takeUntilOther, tap, tap, tap, then, then, thenEmpty, thenMany, thenReturn, timed, timed, timeout, timeout, timeout, timeout, timeout, timeout, timestamp, timestamp, toFuture, toString, transform, transformDeferred, transformDeferredContextual, using, using, using, using, usingWhen, usingWhen, when, when, whenDelayError, whenDelayError, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipDelayError, zipWhen, zipWhen, zipWith, zipWith

Methods inherited from class java.lang.Object

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

Methods inherited from interface reactor.core.Scannable

actuals, inners, isScanAvailable, name, parents, scan, scanOrDefault, stepName, steps, tags, tagsDeduplicated

Method Details

asByteBuffer

public final Mono<ByteBuffer> asByteBuffer()

a ByteBuffer inbound Mono.

Returns:

a ByteBuffer inbound Mono

asByteArray

public final Mono<byte[]> asByteArray()

a byte[] inbound Mono.

Returns:

a byte[] inbound Mono

asString

public final Mono<String> asString()

a String inbound Mono.

Returns:

a String inbound Mono

asString

public final Mono<String> asString(Charset charset)

a String inbound Mono.

Parameters:

charset - the decoding charset

Returns:

a String inbound Mono

asInputStream

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:

a InputStream inbound Mono

fromString

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

Decorate as ByteBufMono.

Parameters:

source - publisher to decorate

Returns:

a ByteBufMono

fromString

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

Decorate as ByteBufMono.

Parameters:

source - publisher to decorate

charset - the encoding charset

allocator - the ByteBufAllocator

Returns:

a ByteBufMono

retain

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 of retained ByteBuf

subscribe

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

Specified by:

subscribe in interface CorePublisher<ByteBuf>

Specified by:

subscribe in class Mono<ByteBuf>