Top Inners Fields Constructors Methods
reactor.core.publisher

pack-priv final Class FluxReplay<T>

extends ConnectableFlux<T>
implements Scannable, Fuseable, OptimizableOperator<T, T>
Class Inheritance
All Implemented Interfaces
reactor.core.publisher.OptimizableOperator, reactor.core.CorePublisher, org.reactivestreams.Publisher, reactor.core.Fuseable, reactor.core.Scannable
Imports
java.util.Objects, java.util.concurrent.CancellationException, .TimeUnit, java.util.concurrent.atomic.AtomicIntegerFieldUpdater, .AtomicLongFieldUpdater, .AtomicReference, .AtomicReferenceFieldUpdater, java.util.function.Consumer, java.util.stream.Stream, org.reactivestreams.Subscriber, .Subscription, reactor.core.CorePublisher, .CoreSubscriber, .Disposable, .Fuseable, .Scannable, reactor.core.scheduler.Scheduler, reactor.util.annotation.Nullable, reactor.util.concurrent.Queues, reactor.util.context.Context
See Also
Reactive-Streams-Commons

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static interface
FluxReplay.ReplayBuffer<T>

pack-priv static class
FluxReplay.ReplayInner<T>

pack-priv static class
FluxReplay.ReplaySubscriber<T>

pack-priv static interface
FluxReplay.ReplaySubscription<T>

pack-priv static class
FluxReplay.SizeAndTimeBoundReplayBuffer<T>

pack-priv static class
FluxReplay.SizeBoundReplayBuffer<T>

pack-priv static class
FluxReplay.UnboundedReplayBuffer<T>

Field Summary

Modifier and TypeField and Description
pack-priv volatile FluxReplay.ReplaySubscriber<T>
connection

pack-priv static final AtomicReferenceFieldUpdater<FluxReplay<T>, FluxReplay.ReplaySubscriber<T>>
CONNECTION

pack-priv final int
history

pack-priv final OptimizableOperator<?, T>
optimizableOperator

pack-priv final Scheduler
scheduler

pack-priv final CorePublisher<T>
source

pack-priv final long
ttl

Inherited from reactor.core.publisher.ConnectableFlux:
NOOP_DISCONNECT

Constructor Summary

AccessConstructor and Description
pack-priv
FluxReplay(CorePublisher<T> source, int history, long ttl, Scheduler scheduler)

Method Summary

Modifier and TypeMethod and Description
public void
connect(Consumer<? super Disposable>
the callback is called with a Disposable instance that can be called to disconnect the source, even synchronously.
cancelSupport)

Implements abstract reactor.core.publisher.ConnectableFlux.connect.

Connects this ConnectableFlux to its source and sends a Disposable to a callback that can be used for disconnecting.
public int
getPrefetch()

Overrides reactor.core.publisher.Flux.getPrefetch.

The prefetch configuration of the Flux
pack-priv FluxReplay.ReplaySubscriber<T>
newState()

public final OptimizableOperator<?, ? extends T>
nextOptimizableSource()

Implements reactor.core.publisher.OptimizableOperator.nextOptimizableSource.

Allow delegation of the subscription by returning the next OptimizableOperator UP in the chain, to be subscribed to next.
public Object
scanUnsafe(Scannable.Attr<T>
a Attr to resolve for the component.
key)

Implements reactor.core.Scannable.scanUnsafe.

This method is used internally by components to define their key-value mappings in a single place.
public final CorePublisher<? extends T>
source()

Implements reactor.core.publisher.OptimizableOperator.source.

public void
subscribe(CoreSubscriber<? super T>
the Subscriber interested into the published sequence
actual)

Implements abstract reactor.core.publisher.Flux.subscribe.

Implements reactor.core.CorePublisher.subscribe.

An internal Publisher#subscribe(Subscriber) that will bypass Hooks#onLastOperator(Function) pointcut.
public final CoreSubscriber<? super T>
subscribeOrReturn(CoreSubscriber<? super T> actual)

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.ConnectableFlux:
autoConnectautoConnectautoConnectconnecthiderefCountrefCountrefCountrefCount