Top Description Inners Fields Constructors Methods
reactor.core.publisher

pack-priv final Class FluxBufferWhen<T, OPEN, CLOSE, BUFFER extends java.util.Collection<? super T>>

extends InternalFluxOperator<T, BUFFER extends Collection<? super T>>
Class Inheritance
Type Parameters
<T>
the source value type
<OPEN>
the value type of the publisher opening the buffers
<CLOSE>
the value type of the publisher closing the individual buffers
<BUFFER>
the collection type that holds the buffered values
Imports
java.util.Collection, .LinkedHashMap, .Map, .Objects, .Queue, java.util.concurrent.atomic.AtomicIntegerFieldUpdater, .AtomicLongFieldUpdater, .AtomicReferenceFieldUpdater, java.util.function.Function, .Supplier, org.reactivestreams.Publisher, .Subscriber, .Subscription, reactor.core.CoreSubscriber, .Disposable, .Disposables, .Exceptions, reactor.util.annotation.Nullable, reactor.util.context.Context
Buffers elements into possibly overlapping buffers whose boundaries are determined by a start Publisher's element and a signal of a derived Publisher
See Also
Reactive-Streams-Commons

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
FluxBufferWhen.BufferWhenCloseSubscriber<T, BUFFER extends Collection<? super T>>

pack-priv static class
FluxBufferWhen.BufferWhenMainSubscriber<T, OPEN, CLOSE, BUFFER extends Collection<? super T>>

pack-priv static class
FluxBufferWhen.BufferWhenOpenSubscriber<OPEN>

Field Summary

Modifier and TypeField and Description
pack-priv final Supplier<BUFFER>
bufferSupplier

pack-priv final Function<? super OPEN, ? extends Publisher<CLOSE>>
end

pack-priv final Supplier<? extends Queue<BUFFER>>
queueSupplier

pack-priv final Publisher<OPEN>
start

Inherited from reactor.core.publisher.InternalFluxOperator:
optimizableOperator

Constructor Summary

AccessConstructor and Description
pack-priv
FluxBufferWhen(Flux<? extends T> source, Publisher<OPEN> start, Function<? super OPEN, ? extends Publisher<CLOSE>> end, Supplier<BUFFER> bufferSupplier, Supplier<? extends Queue<BUFFER>> queueSupplier)

Method Summary

Modifier and TypeMethod and Description
public int
getPrefetch()

Overrides reactor.core.publisher.Flux.getPrefetch.

The prefetch configuration of the Flux
public Object
scanUnsafe(Scannable.Attr<T>
a Attr to resolve for the component.
key)

Overrides reactor.core.publisher.InternalFluxOperator.scanUnsafe.

Implements reactor.core.Scannable.scanUnsafe.

This method is used internally by components to define their key-value mappings in a single place.
public CoreSubscriber<? super T>
subscribeOrReturn(CoreSubscriber<? super BUFFER> actual)

Implements abstract reactor.core.publisher.InternalFluxOperator.subscribeOrReturn.

Implements reactor.core.publisher.OptimizableOperator.subscribeOrReturn.

Allow delegation of the subscription by returning a CoreSubscriber, or force subscription encapsulation by returning null.
Inherited from reactor.core.publisher.InternalFluxOperator:
nextOptimizableSourcesourcesubscribe