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:

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

public class ByteBufMono
extends reactor.core.publisher.MonoOperator<io.netty.buffer.ByteBuf,io.netty.buffer.ByteBuf>

A decorating Mono NettyInbound with various ByteBuf related operations.

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

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
static ByteBufMono	fromString(org.reactivestreams.Publisher<? extends java.lang.String> source) Decorate as ByteBufMono
static ByteBufMono	fromString(org.reactivestreams.Publisher<? extends java.lang.String> source, java.nio.charset.Charset charset, io.netty.buffer.ByteBufAllocator allocator) Decorate as ByteBufMono
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, concatWith, contextWrite, contextWrite, create, defaultIfEmpty, defer, deferContextual, deferWithContext, delay, delay, delayElement, delayElement, delaySubscription, delaySubscription, delaySubscription, delayUntil, dematerialize, doAfterSuccessOrError, doAfterTerminate, doFinally, doFirst, 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, firstWithSignal, firstWithSignal, firstWithValue, firstWithValue, 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, 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, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscriberContext, subscriberContext, subscriberContext, subscribeWith, switchIfEmpty, tag, take, take, takeUntilOther, then, then, thenEmpty, thenMany, thenReturn, timed, timed, timeout, timeout, timeout, timeout, timeout, timeout, timestamp, timestamp, toFuture, toProcessor, toString, transform, transformDeferred, transformDeferredContextual, 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

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 final reactor.core.publisher.Mono<java.io.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(org.reactivestreams.Publisher<? extends java.lang.String> source)

Decorate as ByteBufMono

Parameters:

source - publisher to decorate

Returns:

a ByteBufMono

fromString

public static ByteBufMono fromString(org.reactivestreams.Publisher<? extends java.lang.String> source,
                                     java.nio.charset.Charset charset,
                                     io.netty.buffer.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(reactor.core.CoreSubscriber<? super io.netty.buffer.ByteBuf> actual)

Specified by:

subscribe in interface reactor.core.CorePublisher<io.netty.buffer.ByteBuf>

Specified by:

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