Top Description Inners Fields Constructors Methods

reactor.core.publisher

pack-priv final Class FluxWindow<T>

Class Inheritance

extends InternalFluxOperator<T, Flux<T>>

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

Type Parameters

<T>: the value type

Imports

java.util.ArrayDeque, .Objects, .Queue, java.util.concurrent.atomic.AtomicIntegerFieldUpdater, .AtomicLongFieldUpdater, java.util.function.Supplier, java.util.stream.Stream, org.reactivestreams.Subscriber, .Subscription, reactor.core.CoreSubscriber, .Disposable, .Scannable, reactor.util.annotation.Nullable, reactor.util.context.Context

Splits the source sequence into possibly overlapping publishers.

See Also: https://github.com/reactor/reactive-streams-commons

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static class	FluxWindow.WindowExactSubscriber<T>
pack-priv static class	FluxWindow.WindowOverlapSubscriber<T>
pack-priv static class	FluxWindow.WindowSkipSubscriber<T>

Field Summary

Modifier and Type	Field and Description
pack-priv final Supplier<? extends Queue<Sinks.Many<T>>>	overflowQueueSupplier
pack-priv final Supplier<? extends Queue<T>>	processorQueueSupplier
pack-priv final int	size
pack-priv final int	skip

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

Constructor Summary

Access	Constructor and Description
pack-priv	FluxWindow(Flux<? extends T> source, int size, Supplier<? extends Queue<T>> processorQueueSupplier)
pack-priv	FluxWindow(Flux<? extends T> source, int size, int skip, Supplier<? extends Queue<T>> processorQueueSupplier, Supplier<? extends Queue<Sinks.Many<T>>> overflowQueueSupplier)

Method Summary

Modifier and Type	Method and Description
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