public class ByteBufMono extends MonoOperator<ByteBuf,ByteBuf>
Scannable.Attr<T>
source
OPERATOR_NAME_UNRELATED_WORDS_PATTERN
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)
|
static ByteBufMono |
fromString(Publisher<? extends String> source)
Decorate as
ByteBufMono |
static ByteBufMono |
fromString(Publisher<? extends String> source,
Charset charset,
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(CoreSubscriber<? super ByteBuf> actual) |
scanUnsafe
and, as, block, block, blockOptional, blockOptional, cache, 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, mapNotNull, 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
public final Mono<ByteBuffer> asByteBuffer()
ByteBuffer
inbound Mono
ByteBuffer
inbound Mono
public final Mono<byte[]> asByteArray()
Mono
Mono
public final Mono<InputStream> asInputStream()
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
InputStream
inbound Mono
public static ByteBufMono fromString(Publisher<? extends String> source)
ByteBufMono
source
- publisher to decorateByteBufMono
public static ByteBufMono fromString(Publisher<? extends String> source, Charset charset, ByteBufAllocator allocator)
ByteBufMono
source
- publisher to decoratecharset
- the encoding charsetallocator
- the ByteBufAllocator
ByteBufMono
public final ByteBufMono retain()
ByteBufMono
of retained ByteBuf
public void subscribe(CoreSubscriber<? super ByteBuf> actual)