public class ByteBufMono extends MonoOperator<ByteBuf,ByteBuf>
Scannable.Attr<T>sourceOPERATOR_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) |
scanUnsafeand, as, block, block, blockOptional, blockOptional, cache, cache, cache, cache, cache, cacheInvalidateIf, cacheInvalidateWhen, cacheInvalidateWhen, 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, zipWithpublic final Mono<ByteBuffer> asByteBuffer()
ByteBuffer inbound MonoByteBuffer inbound Monopublic final Mono<byte[]> asByteArray()
MonoMonopublic 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 Monopublic static ByteBufMono fromString(Publisher<? extends String> source)
ByteBufMonosource - publisher to decorateByteBufMonopublic static ByteBufMono fromString(Publisher<? extends String> source, Charset charset, ByteBufAllocator allocator)
ByteBufMonosource - publisher to decoratecharset - the encoding charsetallocator - the ByteBufAllocatorByteBufMonopublic final ByteBufMono retain()
ByteBufMono of retained ByteBufpublic void subscribe(CoreSubscriber<? super ByteBuf> actual)