public class ByteBufFlux extends FluxOperator<ByteBuf,ByteBuf>
Scannable.Attr<T>sourceOPERATOR_NAME_UNRELATED_WORDS_PATTERN| Modifier and Type | Method and Description |
|---|---|
ByteBufMono |
aggregate()
Aggregate subsequent byte buffers into a single buffer.
|
Flux<byte[]> |
asByteArray()
Convert to a byte[] inbound
Flux. |
Flux<ByteBuffer> |
asByteBuffer()
Convert to a
ByteBuffer inbound Flux. |
Flux<InputStream> |
asInputStream()
Convert to an
InputStream inbound Flux |
Flux<String> |
asString()
|
Flux<String> |
asString(Charset charset)
|
static ByteBufFlux |
fromInbound(Publisher<?> source)
Decorate as
ByteBufFlux. |
static ByteBufFlux |
fromInbound(Publisher<?> source,
ByteBufAllocator allocator)
Decorate as
ByteBufFlux. |
static ByteBufFlux |
fromPath(Path path)
Open a
FileChannel from a path and stream
ByteBuf chunks with a default maximum size of 500K into
the returned ByteBufFlux. |
static ByteBufFlux |
fromPath(Path path,
ByteBufAllocator allocator)
Open a
FileChannel from a path and stream
ByteBuf chunks with a default maximum size of 500K into the returned
ByteBufFlux, using the provided ByteBufAllocator. |
static ByteBufFlux |
fromPath(Path path,
int maxChunkSize)
Open a
FileChannel from a path and stream
ByteBuf chunks with a given maximum size into the returned ByteBufFlux. |
static ByteBufFlux |
fromPath(Path path,
int maxChunkSize,
ByteBufAllocator allocator)
Open a
FileChannel from a path and stream
ByteBuf chunks with a given maximum size into the returned
ByteBufFlux, using the provided ByteBufAllocator. |
static ByteBufFlux |
fromString(Publisher<? extends String> source)
Decorate as
ByteBufFlux. |
static ByteBufFlux |
fromString(Publisher<? extends String> source,
Charset charset,
ByteBufAllocator allocator)
Decorate as
ByteBufFlux. |
ByteBufMono |
multicast()
Allow multiple consumers downstream of the flux while also disabling auto memory
release on each buffer published (retaining in order to prevent premature recycling).
|
ByteBufFlux |
retain()
Disable auto memory release on each buffer published, retaining in order to prevent
premature recycling when buffers are accumulated downstream (async).
|
void |
subscribe(CoreSubscriber<? super ByteBuf> s) |
scanUnsafeall, any, as, blockFirst, blockFirst, blockLast, blockLast, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, bufferTimeout, bufferTimeout, bufferTimeout, bufferTimeout, bufferUntil, bufferUntil, bufferUntilChanged, bufferUntilChanged, bufferUntilChanged, bufferWhen, bufferWhen, bufferWhile, cache, cache, cache, cache, cache, cache, cancelOn, cast, checkpoint, checkpoint, checkpoint, collect, collect, collectList, collectMap, collectMap, collectMap, collectMultimap, collectMultimap, collectMultimap, collectSortedList, collectSortedList, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, concat, concat, concat, concat, concatDelayError, concatDelayError, concatDelayError, concatDelayError, concatMap, concatMap, concatMapDelayError, concatMapDelayError, concatMapDelayError, concatMapIterable, concatMapIterable, concatWith, concatWithValues, contextWrite, contextWrite, count, create, create, defaultIfEmpty, defer, deferContextual, deferWithContext, delayElements, delayElements, delaySequence, delaySequence, delaySubscription, delaySubscription, delaySubscription, delayUntil, dematerialize, distinct, distinct, distinct, distinct, distinctUntilChanged, distinctUntilChanged, distinctUntilChanged, doAfterTerminate, doFinally, doFirst, doOnCancel, doOnComplete, doOnDiscard, doOnEach, doOnError, doOnError, doOnError, doOnNext, doOnRequest, doOnSubscribe, doOnTerminate, elapsed, elapsed, elementAt, elementAt, empty, error, error, error, expand, expand, expandDeep, expandDeep, filter, filterWhen, filterWhen, first, first, firstWithSignal, firstWithSignal, firstWithValue, firstWithValue, flatMap, flatMap, flatMap, flatMap, flatMapDelayError, flatMapIterable, flatMapIterable, flatMapSequential, flatMapSequential, flatMapSequential, flatMapSequentialDelayError, from, fromArray, fromIterable, fromStream, fromStream, generate, generate, generate, getPrefetch, groupBy, groupBy, groupBy, groupBy, groupJoin, handle, hasElement, hasElements, hide, ignoreElements, index, index, interval, interval, interval, interval, join, just, just, last, last, limitRate, limitRate, limitRequest, log, log, log, log, log, log, map, mapNotNull, materialize, merge, merge, merge, merge, merge, merge, mergeComparing, mergeComparing, mergeComparing, mergeComparingDelayError, mergeComparingWith, mergeDelayError, mergeOrdered, mergeOrdered, mergeOrdered, mergeOrderedWith, mergePriority, mergePriority, mergePriority, mergePriorityDelayError, mergeSequential, mergeSequential, mergeSequential, mergeSequential, mergeSequential, mergeSequential, mergeSequentialDelayError, mergeSequentialDelayError, mergeSequentialDelayError, mergeWith, metrics, name, never, next, ofType, onAssembly, onAssembly, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureBuffer, onBackpressureDrop, onBackpressureDrop, onBackpressureError, onBackpressureLatest, onErrorComplete, onErrorComplete, onErrorComplete, onErrorContinue, onErrorContinue, onErrorContinue, onErrorMap, onErrorMap, onErrorMap, onErrorResume, onErrorResume, onErrorResume, onErrorReturn, onErrorReturn, onErrorReturn, onErrorStop, onTerminateDetach, or, parallel, parallel, parallel, publish, publish, publish, publish, publishNext, publishOn, publishOn, publishOn, push, push, range, reduce, reduce, reduceWith, repeat, repeat, repeat, repeat, repeatWhen, replay, replay, replay, replay, replay, replay, retry, retry, retryWhen, sample, sample, sampleFirst, sampleFirst, sampleTimeout, sampleTimeout, scan, scan, scanWith, share, shareNext, single, single, singleOrEmpty, skip, skip, skip, skipLast, skipUntil, skipUntilOther, skipWhile, sort, sort, startWith, startWith, startWith, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeOn, subscriberContext, subscriberContext, subscribeWith, switchIfEmpty, switchMap, switchMap, switchOnFirst, switchOnFirst, switchOnNext, switchOnNext, tag, take, take, take, take, takeLast, takeUntil, takeUntilOther, takeWhile, then, then, thenEmpty, thenMany, timed, timed, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timestamp, timestamp, toIterable, toIterable, toIterable, toStream, toStream, toString, transform, transformDeferred, transformDeferredContextual, using, using, usingWhen, usingWhen, window, window, window, window, window, window, window, windowTimeout, windowTimeout, windowTimeout, windowTimeout, windowUntil, windowUntil, windowUntil, windowUntilChanged, windowUntilChanged, windowUntilChanged, windowWhen, windowWhile, windowWhile, withLatestFrom, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipWith, zipWith, zipWith, zipWith, zipWithIterable, zipWithIterablepublic static ByteBufFlux fromInbound(Publisher<?> source)
ByteBufFlux.source - publisher to decorateByteBufFluxpublic static ByteBufFlux fromInbound(Publisher<?> source, ByteBufAllocator allocator)
ByteBufFlux.source - publisher to decorateallocator - the channel ByteBufAllocatorByteBufFluxpublic static ByteBufFlux fromString(Publisher<? extends String> source)
ByteBufFlux.source - publisher to decorateByteBufFluxpublic static ByteBufFlux fromString(Publisher<? extends String> source, Charset charset, ByteBufAllocator allocator)
ByteBufFlux.source - publisher to decoratecharset - the encoding charsetallocator - the ByteBufAllocatorByteBufFluxpublic static ByteBufFlux fromPath(Path path)
FileChannel from a path and stream
ByteBuf chunks with a default maximum size of 500K into
the returned ByteBufFlux.path - the path to the resource to streamByteBufFluxpublic static ByteBufFlux fromPath(Path path, int maxChunkSize)
FileChannel from a path and stream
ByteBuf chunks with a given maximum size into the returned ByteBufFlux.path - the path to the resource to streammaxChunkSize - the maximum per-item ByteBuf sizeByteBufFluxpublic static ByteBufFlux fromPath(Path path, ByteBufAllocator allocator)
FileChannel from a path and stream
ByteBuf chunks with a default maximum size of 500K into the returned
ByteBufFlux, using the provided ByteBufAllocator.path - the path to the resource to streamallocator - the channel ByteBufAllocatorByteBufFluxpublic static ByteBufFlux fromPath(Path path, int maxChunkSize, ByteBufAllocator allocator)
FileChannel from a path and stream
ByteBuf chunks with a given maximum size into the returned
ByteBufFlux, using the provided ByteBufAllocator.path - the path to the resource to streammaxChunkSize - the maximum per-item ByteBuf sizeallocator - the channel ByteBufAllocatorByteBufFluxpublic final Flux<ByteBuffer> asByteBuffer()
ByteBuffer inbound Flux.ByteBuffer inbound Fluxpublic final Flux<byte[]> asByteArray()
Flux.Fluxpublic final Flux<InputStream> asInputStream()
InputStream inbound Flux
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 Fluxpublic final ByteBufMono aggregate()
ByteBufMono of aggregated ByteBufpublic final ByteBufMono multicast()
ByteBufMono of retained ByteBufpublic final ByteBufFlux retain()
ByteBufFlux of retained ByteBufpublic void subscribe(CoreSubscriber<? super ByteBuf> s)