Top Description Inners Fields Constructors Methods

reactor.core.publisher

pack-priv final Class FluxTimeout<T, U, V>

Class Inheritance

extends InternalFluxOperator<T, T>

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

Type Parameters

<T>: the main source type
<U>: the value type for the timeout for the very first item
<V>: the value type for the timeout for the subsequent items

Imports

java.util.Objects, java.util.concurrent.TimeoutException, java.util.concurrent.atomic.AtomicLongFieldUpdater, .AtomicReferenceFieldUpdater, java.util.function.Function, org.reactivestreams.Publisher, .Subscriber, .Subscription, reactor.core.CoreSubscriber, .Scannable, reactor.util.annotation.Nullable, reactor.util.context.Context

Signals a timeout (or switches to another sequence) in case a per-item generated Publisher source fires an item or completes before the next item arrives from the main source.

See Also: Reactive-Streams-Commons

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static enum	FluxTimeout.CancelledIndexedCancellable
pack-priv static interface	FluxTimeout.IndexedCancellable
pack-priv static class	FluxTimeout.TimeoutMainSubscriber<T, V>
pack-priv static class	FluxTimeout.TimeoutOtherSubscriber<T>
pack-priv static class	FluxTimeout.TimeoutTimeoutSubscriber

Field Summary

Modifier and Type	Field and Description
pack-priv final Publisher<U>	firstTimeout
pack-priv final Function<? super T, ? extends Publisher<V>>	itemTimeout
pack-priv final Publisher<? extends T>	other
pack-priv final String	timeoutDescription

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

Constructor Summary

Access	Constructor and Description
pack-priv	FluxTimeout(Flux<? extends T> source, Publisher<U> firstTimeout, Function<? super T, ? extends Publisher<V>> itemTimeout, String timeoutDescription)
pack-priv	FluxTimeout(Flux<? extends T> source, Publisher<U> firstTimeout, Function<? super T, ? extends Publisher<V>> itemTimeout, Publisher<? extends T> other)

Method Summary

Modifier and Type	Method and Description
pack-priv static String	addNameToTimeoutDescription(Publisher<?> source, String timeoutDescription)
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 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