public class ByteBufMono
extends reactor.core.publisher.MonoOperator<io.netty.buffer.ByteBuf,io.netty.buffer.ByteBuf>
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<byte[]> |
asByteArray()
a byte[] inbound
Mono |
reactor.core.publisher.Mono<java.nio.ByteBuffer> |
asByteBuffer()
a
ByteBuffer inbound Mono |
reactor.core.publisher.Mono<java.io.InputStream> |
asInputStream()
Convert to an
InputStream inbound Mono |
reactor.core.publisher.Mono<java.lang.String> |
asString()
a
String inbound Mono |
reactor.core.publisher.Mono<java.lang.String> |
asString(java.nio.charset.Charset charset)
a
String inbound Mono |
static ByteBufMono |
fromString(org.reactivestreams.Publisher<? extends java.lang.String> source)
Decorate as
ByteBufMono |
static ByteBufMono |
fromString(org.reactivestreams.Publisher<? extends java.lang.String> source,
java.nio.charset.Charset charset,
io.netty.buffer.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(reactor.core.CoreSubscriber<? super io.netty.buffer.ByteBuf> actual) |
and, as, block, block, blockOptional, blockOptional, 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, 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 reactor.core.publisher.Mono<java.nio.ByteBuffer> asByteBuffer()
ByteBuffer
inbound Mono
ByteBuffer
inbound Mono
public final reactor.core.publisher.Mono<byte[]> asByteArray()
Mono
Mono
public final reactor.core.publisher.Mono<java.lang.String> asString()
String
inbound Mono
String
inbound Mono
public final reactor.core.publisher.Mono<java.lang.String> asString(java.nio.charset.Charset charset)
String
inbound Mono
charset
- the decoding charsetString
inbound Mono
public final reactor.core.publisher.Mono<java.io.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(org.reactivestreams.Publisher<? extends java.lang.String> source)
ByteBufMono
source
- publisher to decorateByteBufMono
public static ByteBufMono fromString(org.reactivestreams.Publisher<? extends java.lang.String> source, java.nio.charset.Charset charset, io.netty.buffer.ByteBufAllocator allocator)
ByteBufMono
source
- publisher to decoratecharset
- the encoding charsetallocator
- the ByteBufAllocator
ByteBufMono
public final ByteBufMono retain()
ByteBufMono
of retained ByteBuf
public void subscribe(reactor.core.CoreSubscriber<? super io.netty.buffer.ByteBuf> actual)
subscribe
in interface reactor.core.CorePublisher<io.netty.buffer.ByteBuf>
subscribe
in class reactor.core.publisher.Mono<io.netty.buffer.ByteBuf>