Reactor Core 3.6.0 · reactor.core.publisher.SinkManyReplayProcessor

Modifier and Type	Class and Description
pack-priv static class	SinkManyReplayProcessor.ReplayInner<T>

Modifier and Type	Field and Description
pack-priv final FluxReplay.ReplayBuffer<T>	buffer
pack-priv volatile FluxReplay.ReplaySubscription<T>[]	subscribers
pack-priv static final AtomicReferenceFieldUpdater<SinkManyReplayProcessor<T>, FluxReplay.ReplaySubscription<T>[]>	SUBSCRIBERS
pack-priv Subscription	subscription

Access	Constructor and Description
pack-priv	SinkManyReplayProcessor(FluxReplay.ReplayBuffer<T> buffer)

Method Summary

Modifier and Type	Method and Description
pack-priv boolean	add(FluxReplay.ReplaySubscription<T> rs)
public Flux<T>	asFlux() Implements reactor.core.publisher.Sinks.Many.asFlux. Return a `Flux` view of this sink.
pack-priv static < the type of the pushed elements T> SinkManyReplayProcessor<T>	Returns: a new `SinkManyReplayProcessor` that replays its last pushed element to each new `Subscriber` cacheLast() Create a `SinkManyReplayProcessor` that caches the last element it has pushed, replaying it to late subscribers.
pack-priv static < the type of the pushed elements T> SinkManyReplayProcessor<T>	Returns: a new `SinkManyReplayProcessor` that replays its last pushed element to each new `Subscriber`, or a default one if nothing was pushed yet cacheLastOrDefault(T a default value to start the sequence with in case nothing has been cached yet. value) Create a `SinkManyReplayProcessor` that caches the last element it has pushed, replaying it to late subscribers.
pack-priv static < the type of the pushed elements E> SinkManyReplayProcessor<E>	Returns: a new `SinkManyReplayProcessor` that replays the whole history to each new `Subscriber`. create() Create a new `SinkManyReplayProcessor` that replays an unbounded number of elements, using a default internal `Queue`.
pack-priv static < the type of the pushed elements E> SinkManyReplayProcessor<E>	Returns: a new `SinkManyReplayProcessor` that replays a limited history to each new `Subscriber`. create(int the backlog size, ie. maximum items retained for replay. historySize) Create a new `SinkManyReplayProcessor` that replays up to `historySize` elements.
pack-priv static < the type of the pushed elements E> SinkManyReplayProcessor<E>	Returns: a new `SinkManyReplayProcessor` that replays the whole history to each new `Subscriber` if configured as unbounded, a limited history otherwise. create(int maximum items retained if bounded, or initial link size if unbounded historySize, boolean true if "unlimited" data store must be supplied unbounded) Create a new `SinkManyReplayProcessor` that either replay all the elements or a limited amount of elements depending on the `unbounded` parameter.
pack-priv static < the type of items observed and emitted by the sink T> SinkManyReplayProcessor<T>	Returns: a new `SinkManyReplayProcessor` that replay up to `size` elements, but will evict them from its history based on their age. createSizeAndTimeout(int the maximum number of buffered items size, Duration the maximum age of the contained items maxAge) Creates a time- and size-bounded replay processor.
pack-priv static < the type of items observed and emitted by the sink T> SinkManyReplayProcessor<T>	Returns: a new `SinkManyReplayProcessor` that replay up to `size` elements, but will evict them from its history based on their age. createSizeAndTimeout(int the maximum number of buffered items size, Duration the maximum age of the contained items in milliseconds maxAge, Scheduler the `Scheduler` that provides the current time scheduler) Creates a time- and size-bounded replay processor.
pack-priv static < the type of items observed and emitted by the sink T> SinkManyReplayProcessor<T>	Returns: a new `SinkManyReplayProcessor` that replays elements based on their age. createTimeout(Duration the maximum age of the contained items maxAge) Creates a time-bounded replay processor.
pack-priv static < the type of items observed and emitted by the sink T> SinkManyReplayProcessor<T>	Returns: a new `SinkManyReplayProcessor` that replays elements based on their age. createTimeout(Duration the maximum age of the contained items maxAge, Scheduler scheduler) Creates a time-bounded replay processor.
public Context	currentContext() Overrides default reactor.core.CoreSubscriber.currentContext. Implements reactor.core.publisher.ContextHolder.currentContext. Request a `Context` from dependent components which can include downstream operators during subscribing or a terminal `org.reactivestreams.Subscriber`.
public int	currentSubscriberCount() Implements reactor.core.publisher.Sinks.Many.currentSubscriberCount. Get how many `Subscribers` are currently subscribed to the sink.
public void	dispose() Implements reactor.core.Disposable.dispose. Cancel or dispose the underlying task or resource.
public int	getPrefetch() Overrides reactor.core.publisher.Flux.getPrefetch. The prefetch configuration of the `Flux`
public Stream<? extends Scannable>	inners() Overrides default reactor.core.Scannable.inners. Return a `Stream` of referenced inners (flatmap, multicast etc)
public boolean	isDisposed() Overrides default reactor.core.Disposable.isDisposed. Optionally return true when the resource or task is disposed.
public void	onComplete() Implements org.reactivestreams.Subscriber.onComplete. Successful terminal state.
public void	onError(Throwable the throwable signaled throwable) Implements org.reactivestreams.Subscriber.onError. Failed terminal state.
public void	onNext(T the element signaled t) Implements org.reactivestreams.Subscriber.onNext. Data notification sent by the `Publisher` in response to requests to `Subscription#request(long)`.
public void	onSubscribe(Subscription the `Subscription` that allows requesting data via `Subscription#request(long)` s) Implements reactor.core.CoreSubscriber.onSubscribe. Implementors should initialize any state used by `onNext(Object)` before calling `Subscription#request(long)`.
pack-priv void	remove(FluxReplay.ReplaySubscription<T> rs)
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 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 Sinks.EmitResult	tryEmitComplete() Implements reactor.core.publisher.Sinks.Many.tryEmitComplete. Try to terminate the sequence successfully, generating an `onComplete` signal.
public Sinks.EmitResult	tryEmitError(Throwable the exception to signal, not null t) Implements reactor.core.publisher.Sinks.Many.tryEmitError. Try to fail the sequence, generating an `onError` signal.
public Sinks.EmitResult	tryEmitNext(T the value to emit, not null t) Implements reactor.core.publisher.Sinks.Many.tryEmitNext. Try emitting a non-null element, generating an `onNext` signal.

Inherited from reactor.core.publisher.Flux:: all any as blockFirst blockFirst blockLast blockLast buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer bufferTimeout bufferTimeout bufferTimeout bufferTimeout bufferTimeout bufferTimeout bufferTimeout bufferTimeout bufferUntil bufferUntil bufferUntilChanged bufferUntilChanged bufferUntilChanged bufferWhen bufferWhen bufferWhile cache cache cache cache cache cache cancelOn cast checkpoint checkpoint checkpoint collect collect collectList collectMap collectMap collectMap collectMultimap collectMultimap collectMultimap collectSortedList collectSortedList combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest concat concat concat concat concatDelayError concatDelayError concatDelayError concatDelayError concatMap concatMap concatMapDelayError concatMapDelayError concatMapDelayError concatMapIterable concatMapIterable concatWith concatWithValues contextCapture contextWrite contextWrite count countingBooleanSupplier countingPredicate create create defaultIfEmpty defer deferContextual delayElements delayElements delaySequence delaySequence delaySubscription delaySubscription delaySubscription delayUntil dematerialize distinct distinct distinct distinct distinctUntilChanged distinctUntilChanged distinctUntilChanged doAfterTerminate doFinally doFirst doOnCancel doOnComplete doOnDiscard doOnEach doOnError doOnError doOnError doOnNext doOnRequest doOnSignal doOnSubscribe doOnTerminate elapsed elapsed elementAt elementAt empty equalPredicate error error error expand expand expandDeep expandDeep filter filterWhen filterWhen first first firstWithSignal firstWithSignal firstWithValue firstWithValue flatMap flatMap flatMap flatMap flatMap flatMapDelayError flatMapIterable flatMapIterable flatMapSequential flatMapSequential flatMapSequential flatMapSequential flatMapSequentialDelayError from fromArray fromIterable fromStream fromStream generate generate generate groupBy groupBy groupBy groupBy groupJoin handle hasElement hasElements hashSetSupplier hide identityFunction ignoreElements index index interval interval interval interval join just just last last limitRate limitRate limitRequest listSupplier log log log log log log map mapNotNull materialize merge merge merge merge merge merge merge mergeComparing mergeComparing mergeComparing mergeComparingDelayError mergeComparingWith mergeDelayError mergeOrdered mergeOrdered mergeOrdered mergeOrderedWith mergePriority mergePriority mergePriority mergePriorityDelayError mergeSequential mergeSequential mergeSequential mergeSequential mergeSequential mergeSequential mergeSequential mergeSequential mergeSequential mergeSequentialDelayError mergeSequentialDelayError mergeSequentialDelayError mergeWith metrics name never next ofType onAssembly onAssembly onBackpressureBuffer onBackpressureBuffer onBackpressureBuffer onBackpressureBuffer onBackpressureBuffer onBackpressureBuffer onBackpressureBuffer onBackpressureDrop onBackpressureDrop onBackpressureError onBackpressureLatest onErrorComplete onErrorComplete onErrorComplete onErrorContinue onErrorContinue onErrorContinue onErrorMap onErrorMap onErrorMap onErrorResume onErrorResume onErrorResume onErrorReturn onErrorReturn onErrorReturn onErrorStop onTerminateDetach or parallel parallel parallel publish publish publish publish publishNext publishOn publishOn publishOn publishOn push push range reduce reduce reduceWith repeat repeat repeat repeat repeatWhen replay replay replay replay replay replay retry retry retryWhen sample sample sampleFirst sampleFirst sampleTimeout sampleTimeout scan scan scanWith share shareNext single single singleOrEmpty skip skip skip skipLast skipUntil skipUntilOther skipWhile sort sort startWith startWith startWith subscribe subscribe subscribe subscribe subscribe subscribe subscribe subscribeOn subscribeOn subscribeWith switchIfEmpty switchMap switchMap switchOnFirst switchOnFirst switchOnNext switchOnNext tag take take take take takeLast takeUntil takeUntilOther takeWhile tap tap tap then then thenEmpty thenMany timed timed timeout timeout timeout timeout timeout timeout timeout timestamp timestamp toIterable toIterable toIterable toStream toStream toString transform transformDeferred transformDeferredContextual tuple2Function using using usingWhen usingWhen window window window window window window window windowTimeout windowTimeout windowTimeout windowTimeout windowUntil windowUntil windowUntil windowUntilChanged windowUntilChanged windowUntilChanged windowWhen windowWhile windowWhile withLatestFrom wrap wrapToMono zip zip zip zip zip zip zip zip zip zip zip zip zip zipWith zipWith zipWith zipWith zipWithIterable zipWithIterable

pack-priv final Class SinkManyReplayProcessor<T>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary