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>, Scannable

public final 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>

Field Summary

Fields inherited from class reactor.core.publisher.MonoOperator

source

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ByteBufMono(Mono<?> source)

Method Summary

Modifier and Type	Method and Description
Mono<byte[]>	asByteArray() a byte[] inbound Mono
Mono<java.nio.ByteBuffer>	asByteBuffer() a ByteBuffer inbound Mono
Mono<java.io.InputStream>	asInputStream() Convert to an InputStream inbound Mono
Mono<java.lang.String>	asString() a String inbound Mono
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(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, cancelOn, cast, checkpoint, checkpoint, checkpoint, compose, concatWith, create, defaultIfEmpty, defer, delay, delay, delayElement, delayElement, delaySubscription, delaySubscription, delaySubscription, delayUntil, dematerialize, doAfterSuccessOrError, doAfterTerminate, doFinally, doOnCancel, 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(Mono<?> source)

Method Detail

asByteBuffer

public final Mono<java.nio.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<java.lang.String> asString()

a String inbound Mono

Returns:

a String inbound Mono

asString

public final 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 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(CoreSubscriber<? super ByteBuf> actual)

Specified by:

subscribe in class Mono<ByteBuf>