reactor.netty

Class ByteBufMono

java.lang.Object

reactor.core.publisher.Mono<O>

reactor.core.publisher.MonoOperator<io.netty.buffer.ByteBuf,io.netty.buffer.ByteBuf>

reactor.netty.ByteBufMono

All Implemented Interfaces:

Publisher<io.netty.buffer.ByteBuf>, reactor.core.Scannable

public final class ByteBufMono
extends reactor.core.publisher.MonoOperator<io.netty.buffer.ByteBuf,io.netty.buffer.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

reactor.core.Scannable.Attr<T>

Field Summary

Fields inherited from class reactor.core.publisher.MonoOperator

source

Fields inherited from interface reactor.core.Scannable

OPERATOR_NAME_UNRELATED_WORDS_PATTERN

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ByteBufMono(reactor.core.publisher.Mono<?> source)

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Mono<byte[]>	asByteArray() a byte[] inbound Mono
reactor.core.publisher.Mono<java.nio.ByteBuffer>	asByteBuffer() a ByteBuffer inbound Mono
reactor.core.publisher.Mono<java.io.InputStream>	asInputStream() Convert to an InputStream inbound Mono
reactor.core.publisher.Mono<java.lang.String>	asString() a String inbound Mono
reactor.core.publisher.Mono<java.lang.String>	asString(java.nio.charset.Charset charset) a String inbound Mono
ByteBufMono	retain() Disable auto memory release on each signal published in order to prevent premature recycling when buffers are accumulated downstream (async).
void	subscribe(reactor.core.CoreSubscriber<? super io.netty.buffer.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, cancelOn, cast, checkpoint, checkpoint, checkpoint, compose, concatWith, create, defaultIfEmpty, defer, delay, delay, delayElement, delayElement, delaySubscription, delaySubscription, delaySubscription, delayUntil, dematerialize, doAfterSuccessOrError, doAfterTerminate, doFinally, doOnCancel, doOnDiscard, doOnEach, doOnError, doOnError, doOnError, doOnNext, doOnRequest, doOnSubscribe, doOnSuccess, doOnSuccessOrError, doOnTerminate, elapsed, elapsed, empty, error, error, expand, expand, expandDeep, expandDeep, filter, filterWhen, first, first, flatMap, flatMapIterable, flatMapMany, flatMapMany, flux, from, fromCallable, fromCompletionStage, fromCompletionStage, fromDirect, fromFuture, fromFuture, fromRunnable, fromSupplier, handle, hasElement, hide, ignoreElement, ignoreElements, just, justOrEmpty, justOrEmpty, log, log, log, log, log, log, map, materialize, mergeWith, metrics, name, never, ofType, onAssembly, onErrorMap, onErrorMap, onErrorMap, onErrorResume, onErrorResume, onErrorResume, onErrorReturn, onErrorReturn, onErrorReturn, onLastAssembly, onTerminateDetach, or, publish, publishOn, repeat, repeat, repeat, repeat, repeatWhen, repeatWhenEmpty, repeatWhenEmpty, retry, retry, retry, retry, retryBackoff, retryBackoff, retryBackoff, retryWhen, sequenceEqual, sequenceEqual, sequenceEqual, single, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscriberContext, subscriberContext, subscriberContext, subscribeWith, switchIfEmpty, tag, take, take, takeUntilOther, then, then, thenEmpty, thenMany, thenReturn, timeout, timeout, timeout, timeout, timeout, timeout, timestamp, timestamp, toFuture, toProcessor, toString, transform, 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, from, inners, isScanAvailable, name, parents, scan, scanOrDefault, stepName, steps, tags

Constructor Detail

ByteBufMono

protected ByteBufMono(reactor.core.publisher.Mono<?> source)

Method Detail

asByteBuffer

public final reactor.core.publisher.Mono<java.nio.ByteBuffer> asByteBuffer()

a ByteBuffer inbound Mono

Returns:

a ByteBuffer inbound Mono

asByteArray

public final reactor.core.publisher.Mono<byte[]> asByteArray()

a byte[] inbound Mono

Returns:

a byte[] inbound Mono

asString

public final reactor.core.publisher.Mono<java.lang.String> asString()

a String inbound Mono

Returns:

a String inbound Mono

asString

public final reactor.core.publisher.Mono<java.lang.String> asString(java.nio.charset.Charset charset)

a String inbound Mono

Parameters:

charset - the decoding charset

Returns:

a String inbound Mono

asInputStream

public reactor.core.publisher.Mono<java.io.InputStream> asInputStream()

Convert to an InputStream inbound Mono

Returns:

a InputStream inbound Mono

retain

public 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(reactor.core.CoreSubscriber<? super io.netty.buffer.ByteBuf> actual)

Specified by:

subscribe in class reactor.core.publisher.Mono<io.netty.buffer.ByteBuf>