public class ByteBufFlux extends FluxOperator<ByteBuf,ByteBuf>
Scannable.Attr<T>
source
OPERATOR_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) |
scanUnsafe
all, 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, zipWithIterable
public static ByteBufFlux fromInbound(Publisher<?> source)
ByteBufFlux
source
- publisher to decorateByteBufFlux
public static ByteBufFlux fromInbound(Publisher<?> source, ByteBufAllocator allocator)
ByteBufFlux
source
- publisher to decorateallocator
- the channel ByteBufAllocator
ByteBufFlux
public static ByteBufFlux fromString(Publisher<? extends String> source)
ByteBufFlux
source
- publisher to decorateByteBufFlux
public static ByteBufFlux fromString(Publisher<? extends String> source, Charset charset, ByteBufAllocator allocator)
ByteBufFlux
source
- publisher to decoratecharset
- the encoding charsetallocator
- the ByteBufAllocator
ByteBufFlux
public 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 streamByteBufFlux
public 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 sizeByteBufFlux
public 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 ByteBufAllocator
ByteBufFlux
public 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 ByteBufAllocator
ByteBufFlux
public final Flux<ByteBuffer> asByteBuffer()
ByteBuffer
inbound Flux
ByteBuffer
inbound Flux
public final Flux<byte[]> asByteArray()
Flux
Flux
public 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 Flux
public final ByteBufMono aggregate()
ByteBufMono
of aggregated ByteBuf
public final ByteBufMono multicast()
ByteBufMono
of retained ByteBuf
public final ByteBufFlux retain()
ByteBufFlux
of retained ByteBuf
public void subscribe(CoreSubscriber<? super ByteBuf> s)