Scannable.Attr<T>
source
OPERATOR_NAME_UNRELATED_WORDS_PATTERN
Modifier | Constructor and Description |
---|---|
protected |
ByteBufMono(Mono<?> source) |
Modifier and Type | Method and Description |
---|---|
Mono<byte[]> |
asByteArray()
a byte[] inbound
Mono |
Mono<ByteBuffer> |
asByteBuffer()
a
ByteBuffer inbound Mono |
Mono<InputStream> |
asInputStream()
Convert to an
InputStream inbound Mono |
Mono<String> |
asString()
|
Mono<String> |
asString(Charset charset)
|
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) |
scanUnsafe
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, onErrorContinue, onErrorContinue, onErrorContinue, 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
protected ByteBufMono(Mono<?> source)
public final Mono<ByteBuffer> asByteBuffer()
ByteBuffer
inbound Mono
ByteBuffer
inbound Mono
public final Mono<byte[]> asByteArray()
Mono
Mono
public Mono<InputStream> asInputStream()
InputStream
inbound Mono
InputStream
inbound Mono
public ByteBufMono retain()
ByteBufMono
of retained ByteBuf
public void subscribe(CoreSubscriber<? super ByteBuf> actual)