Package reactor.netty
Class ByteBufMono
- All Implemented Interfaces:
Publisher<ByteBuf>
,CorePublisher<ByteBuf>
,Scannable
- Author:
- Stephane Maldini
-
Nested Class Summary
Nested classes/interfaces inherited from interface reactor.core.Scannable
Scannable.Attr<T extends Object>
-
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 TypeMethodDescriptionfinal Mono<byte[]>
a byte[] inboundMono
.final Mono<ByteBuffer>
aByteBuffer
inboundMono
.final Mono<InputStream>
Convert to anInputStream
inboundMono
asString()
static ByteBufMono
fromString
(Publisher<? extends String> source) Decorate asByteBufMono
.static ByteBufMono
fromString
(Publisher<? extends String> source, Charset charset, ByteBufAllocator allocator) Decorate asByteBufMono
.final 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, cache, cacheInvalidateIf, cacheInvalidateWhen, cacheInvalidateWhen, cancelOn, cast, checkpoint, checkpoint, checkpoint, concatWith, contextCapture, contextWrite, contextWrite, create, defaultIfEmpty, defer, deferContextual, delay, delay, delayElement, delayElement, delaySubscription, delaySubscription, delaySubscription, delayUntil, dematerialize, doAfterTerminate, doFinally, doFirst, doOnCancel, doOnDiscard, doOnEach, doOnError, doOnError, doOnError, doOnNext, doOnRequest, doOnSubscribe, doOnSuccess, 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, 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, onErrorComplete, onErrorComplete, onErrorComplete, 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, singleOptional, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeWith, switchIfEmpty, tag, take, take, takeUntilOther, tap, tap, tap, then, then, thenEmpty, thenMany, thenReturn, timed, timed, timeout, timeout, timeout, timeout, timeout, timeout, timestamp, timestamp, toFuture, toString, transform, transformDeferred, transformDeferredContextual, using, using, 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, inners, isScanAvailable, name, parents, scan, scanOrDefault, stepName, steps, tags, tagsDeduplicated
-
Method Details
-
asByteBuffer
aByteBuffer
inboundMono
.- Returns:
- a
ByteBuffer
inboundMono
-
asByteArray
a byte[] inboundMono
.- Returns:
- a byte[] inbound
Mono
-
asString
-
asString
-
asInputStream
Convert to anInputStream
inboundMono
Note: Auto memory release is disabled. The underlying
ByteBuf
will be released only whenInputStream.close()
is invoked. EnsureInputStream.close()
is invoked for any terminal signal:complete
|error
|cancel
- Returns:
- a
InputStream
inboundMono
-
fromString
Decorate asByteBufMono
.- Parameters:
source
- publisher to decorate- Returns:
- a
ByteBufMono
-
fromString
public static ByteBufMono fromString(Publisher<? extends String> source, Charset charset, ByteBufAllocator allocator) Decorate asByteBufMono
.- Parameters:
source
- publisher to decoratecharset
- the encoding charsetallocator
- theByteBufAllocator
- Returns:
- a
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 retainedByteBuf
-
subscribe
-