pack-priv final Class FluxWindowPredicate<T>

Class Inheritance

extends InternalFluxOperator<T, Flux<T>>
implements Fuseable

java.lang.Object
reactor.core.publisher.Flux
reactor.core.publisher.FluxOperator
reactor.core.publisher.InternalFluxOperator
reactor.core.publisher.FluxWindowPredicate

All Implemented Interfaces

reactor.core.Fuseable

Type Parameters

<T>: the source and window value type

Imports

java.util.Objects, .Queue, java.util.concurrent.atomic.AtomicIntegerFieldUpdater, .AtomicLongFieldUpdater, .AtomicReferenceFieldUpdater, java.util.function.Predicate, .Supplier, java.util.stream.Stream, org.reactivestreams.Subscriber, .Subscription, reactor.core.CoreSubscriber, .Disposable, .Exceptions, .Fuseable, .Scannable, reactor.core.publisher.FluxBufferPredicate.Mode, reactor.util.annotation.Nullable, reactor.util.context.Context

Cut a sequence into non-overlapping windows where each window boundary is determined by a Predicate on the values. The predicate can be used in several modes:

Until: A new window starts when the predicate returns true. The element that just matched the predicate is the last in the previous window, and the windows are not emitted before an inner element is pushed.
UntilOther: A new window starts when the predicate returns true. The element that just matched the predicate is the first in the new window, which is emitted immediately.
While: A new window starts when the predicate stops matching. The non-matching elements that delimit each window are simply discarded, and the windows are not emitted before an inner element is pushed

See Also: Reactive-Streams-Commons

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static class	FluxWindowPredicate.WindowFlux<T>
pack-priv static class	FluxWindowPredicate.WindowPredicateMain<T>

Field Summary

Modifier and Type	Field and Description
pack-priv final Supplier<? extends Queue<T>>	groupQueueSupplier
pack-priv final Supplier<? extends Queue<Flux<T>>>	mainQueueSupplier
pack-priv final FluxBufferPredicate.Mode	mode
pack-priv final Predicate<? super T>	predicate
pack-priv final int	prefetch

Inherited from reactor.core.publisher.InternalFluxOperator:: optimizableOperator

Constructor Summary

Access	Constructor and Description
pack-priv	FluxWindowPredicate(Flux<? extends T> source, Supplier<? extends Queue<Flux<T>>> mainQueueSupplier, Supplier<? extends Queue<T>> groupQueueSupplier, int prefetch, Predicate<? super T> predicate, FluxBufferPredicate.Mode mode)

Method Summary

Modifier and Type	Method 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 Flux<T>> 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:: nextOptimizableSource source subscribe