Top Description Inners Fields Constructors Methods
reactor.core.publisher

pack-priv final Class FluxTake<T>

extends InternalFluxOperator<T, T>
Class Inheritance
Type Parameters
<T>
the value type
Imports
java.util.concurrent.atomic.AtomicIntegerFieldUpdater, org.reactivestreams.Subscription, reactor.core.CoreSubscriber, .Fuseable, .Fuseable.ConditionalSubscriber, .Fuseable.QueueSubscription, reactor.util.annotation.Nullable
Takes only the first N values from the source Publisher.

If N is zero, the subscriber gets completed if the source completes, signals an error or signals its first value (which is not not relayed though).

See Also
Reactive-Streams-Commons

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
FluxTake.TakeConditionalSubscriber<T>

pack-priv static class
FluxTake.TakeFuseableSubscriber<T>

pack-priv static class
FluxTake.TakeSubscriber<T>

Field Summary

Modifier and TypeField and Description
pack-priv final long
n

Inherited from reactor.core.publisher.InternalFluxOperator:
optimizableOperator

Constructor Summary

AccessConstructor and Description
pack-priv
FluxTake(Flux<? extends T> source, long n)

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 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:
nextOptimizableSourcesourcesubscribe