Top Inners Fields Constructors Methods
reactor.core.publisher

pack-priv final Class FluxBufferTimeout<T, C extends java.util.Collection<? super T>>

extends InternalFluxOperator<T, C extends Collection<? super T>>
Class Inheritance
Imports
java.util.Collection, .Objects, .Queue, java.util.concurrent.RejectedExecutionException, .TimeUnit, java.util.concurrent.atomic.AtomicIntegerFieldUpdater, .AtomicLongFieldUpdater, java.util.function.Supplier, org.reactivestreams.Subscriber, .Subscription, reactor.core.CoreSubscriber, .Disposable, .Exceptions, reactor.core.scheduler.Scheduler, reactor.util.Logger, reactor.util.annotation.Nullable, reactor.util.concurrent.Queues, reactor.util.context.Context
Author
Stephane Maldini

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
FluxBufferTimeout.BufferTimeoutSubscriber<T, C extends Collection<? super T>>

pack-priv static class
FluxBufferTimeout.BufferTimeoutWithBackpressureSubscriber<T, C extends Collection<? super T>>

Field Summary

Modifier and TypeField and Description
pack-priv final int
batchSize

pack-priv final Supplier<C>
bufferSupplier

pack-priv final boolean
fairBackpressure

pack-priv final Scheduler
timer

pack-priv final long
timespan

pack-priv final TimeUnit
unit

Inherited from reactor.core.publisher.InternalFluxOperator:
optimizableOperator

Constructor Summary

AccessConstructor and Description
pack-priv
FluxBufferTimeout(Flux<T> source, int maxSize, long timespan, TimeUnit unit, Scheduler timer, Supplier<C> bufferSupplier, boolean fairBackpressure)

Method Summary

Modifier and TypeMethod 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 C> 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