ReplayProcessor (reactor-core 3.4.0-SNAPSHOT)

java.lang.Object
- reactor.core.publisher.Flux<OUT>
- - reactor.core.publisher.FluxProcessor<T,T>
  - - reactor.core.publisher.ReplayProcessor<T>

Type Parameters:

T - the value type

All Implemented Interfaces:

Processor<T,T>, Publisher<T>, Subscriber<T>, CorePublisher<T>, CoreSubscriber<T>, Disposable, Fuseable, Scannable

Deprecated.
To be removed in 3.5, prefer clear cut usage of Sinks through variations under Sinks.many().replay().
```
@Deprecated
public final class ReplayProcessor<T>
extends FluxProcessor<T,T>
implements Fuseable
```
Replays all or the last N items to Subscribers.

Nested Class Summary
- Nested classes/interfaces inherited from interface reactor.core.Fuseable
  Fuseable.ConditionalSubscriber<T>, Fuseable.QueueSubscription<T>, Fuseable.ScalarCallable<T>, Fuseable.SynchronousSubscription<T>
- Nested classes/interfaces inherited from interface reactor.core.Scannable
  Scannable.Attr<T>
- Nested classes/interfaces inherited from interface reactor.core.Disposable
  Disposable.Composite, Disposable.Swap

Field Summary
- Fields inherited from interface reactor.core.Fuseable
  ANY, ASYNC, NONE, SYNC, THREAD_BARRIER
- Fields inherited from interface reactor.core.Scannable
  OPERATOR_NAME_UNRELATED_WORDS_PATTERN

Method Summary

All Methods Static Methods Instance Methods Concrete Methods Default Methods Deprecated Methods
Modifier and Type	Method and Description
`Flux<T>`	`asFlux()` Deprecated. Return a `Flux` view of this sink.
`static <T> ReplayProcessor<T>`	`cacheLast()` Deprecated. Create a `ReplayProcessor` that caches the last element it has pushed, replaying it to late subscribers.
`static <T> ReplayProcessor<T>`	`cacheLastOrDefault(T value)` Deprecated. Create a `ReplayProcessor` that caches the last element it has pushed, replaying it to late subscribers.
`static <E> ReplayProcessor<E>`	`create()` Deprecated. Create a new `ReplayProcessor` that replays an unbounded number of elements, using a default internal `Queue`.
`static <E> ReplayProcessor<E>`	`create(int historySize)` Deprecated. Create a new `ReplayProcessor` that replays up to `historySize` elements.
`static <E> ReplayProcessor<E>`	`create(int historySize, boolean unbounded)` Deprecated. Create a new `ReplayProcessor` that either replay all the elements or a limited amount of elements depending on the `unbounded` parameter.
`static <T> ReplayProcessor<T>`	`createSizeAndTimeout(int size, Duration maxAge)` Deprecated. Creates a time- and size-bounded replay processor.
`static <T> ReplayProcessor<T>`	`createSizeAndTimeout(int size, Duration maxAge, Scheduler scheduler)` Deprecated. Creates a time- and size-bounded replay processor.
`static <T> ReplayProcessor<T>`	`createTimeout(Duration maxAge)` Deprecated. Creates a time-bounded replay processor.
`static <T> ReplayProcessor<T>`	`createTimeout(Duration maxAge, Scheduler scheduler)` Deprecated. Creates a time-bounded replay processor.
`Context`	`currentContext()` Deprecated. Request a `Context` from dependent components which can include downstream operators during subscribing or a terminal `Subscriber`.
`int`	`currentSubscriberCount()` Deprecated. Get how many `Subscribers` are currently subscribed to the sink.
`long`	`downstreamCount()` Deprecated. Return the number of active `Subscriber` or -1 if untracked.
`default void`	`emitComplete(Sinks.EmitFailureHandler failureHandler)` A simplified attempt at completing via the `Sinks.Many.tryEmitComplete()` API, generating an `onComplete` signal.
`default void`	`emitError(Throwable error, Sinks.EmitFailureHandler failureHandler)` A simplified attempt at failing the sequence via the `Sinks.Many.tryEmitError(Throwable)` API, generating an `onError` signal.
`default void`	`emitNext(T value, Sinks.EmitFailureHandler failureHandler)` A simplified attempt at emitting a non-null element via the `Sinks.Many.tryEmitNext(Object)` API, generating an `onNext` signal.
`Throwable`	`getError()` Deprecated. Current error if any, default to null
`int`	`getPrefetch()` Deprecated. The prefetch configuration of the `Flux`
`Stream<? extends Scannable>`	`inners()` Deprecated. Return a `Stream` of referenced inners (flatmap, multicast etc)
`protected boolean`	`isIdentityProcessor()` Deprecated. Return true if `FluxProcessor<T, T>`
`boolean`	`isTerminated()` Deprecated. Has this upstream finished or "completed" / "failed" ?
`void`	`onComplete()` Deprecated.
`void`	`onError(Throwable throwable)` Deprecated.
`void`	`onNext(T t)` Deprecated.
`void`	`onSubscribe(Subscription s)` Deprecated. Implementors should initialize any state used by `Subscriber.onNext(Object)` before calling `Subscription.request(long)`.
`Object`	`scanUnsafe(Scannable.Attr key)` Deprecated. This method is used internally by components to define their key-value mappings in a single place.
`void`	`subscribe(CoreSubscriber<? super T> actual)` Deprecated. An internal `Publisher.subscribe(Subscriber)` that will bypass `Hooks.onLastOperator(Function)` pointcut.
`Sinks.EmitResult`	`tryEmitComplete()` Deprecated. Try to terminate the sequence successfully, generating an `onComplete` signal.
`Sinks.EmitResult`	`tryEmitError(Throwable t)` Deprecated. Try to fail the sequence, generating an `onError` signal.
`Sinks.EmitResult`	`tryEmitNext(T t)` Deprecated. Try emitting a non-null element, generating an `onNext` signal.

Methods inherited from class reactor.core.publisher.FluxProcessor
dispose, getBufferSize, hasCompleted, hasDownstreams, hasError, isSerialized, serialize, serializeAlways, sink, sink, switchOnNext, wrap

Methods inherited from class 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, 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, contextWrite, contextWrite, count, create, create, defaultIfEmpty, defer, deferContextual, deferWithContext, 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, doOnSubscribe, doOnTerminate, elapsed, elapsed, elementAt, elementAt, empty, error, error, error, expand, expand, expandDeep, expandDeep, filter, filterWhen, filterWhen, first, first, firstWithSignal, firstWithSignal, firstWithValue, firstWithValue, flatMap, flatMap, flatMap, flatMap, flatMapDelayError, flatMapIterable, flatMapIterable, flatMapSequential, flatMapSequential, flatMapSequential, flatMapSequentialDelayError, from, fromArray, fromIterable, fromStream, fromStream, generate, generate, generate, groupBy, groupBy, groupBy, groupBy, groupJoin, handle, hasElement, hasElements, hide, ignoreElements, index, index, interval, interval, interval, interval, join, just, just, last, last, limitRate, limitRate, limitRequest, log, log, log, log, log, log, map, materialize, merge, merge, merge, merge, merge, merge, mergeDelayError, mergeOrdered, mergeOrdered, mergeOrdered, mergeOrderedWith, 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, 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, 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, subscriberContext, subscriberContext, subscribeWith, switchIfEmpty, switchMap, switchMap, switchOnFirst, switchOnFirst, switchOnNext, switchOnNext, tag, take, take, take, takeLast, takeUntil, takeUntilOther, takeWhile, then, then, thenEmpty, thenMany, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timestamp, timestamp, toIterable, toIterable, toIterable, toStream, toStream, toString, transform, transformDeferred, transformDeferredContextual, using, using, usingWhen, usingWhen, window, window, window, window, window, window, window, windowTimeout, windowTimeout, windowUntil, windowUntil, windowUntil, windowUntilChanged, windowUntilChanged, windowUntilChanged, windowWhen, windowWhile, windowWhile, withLatestFrom, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipWith, zipWith, zipWith, zipWith, zipWithIterable, zipWithIterable

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface reactor.core.Scannable
actuals, from, isScanAvailable, name, parents, scan, scanOrDefault, stepName, steps, tags

Methods inherited from interface org.reactivestreams.Publisher
subscribe

Methods inherited from interface reactor.core.Disposable
isDisposed

- Method Detail
  - cacheLast
```
public static <T> ReplayProcessor<T> cacheLast()
```
    Deprecated.
    
    Create a ReplayProcessor that caches the last element it has pushed, replaying it to late subscribers. This is a buffer-based ReplayProcessor with a history size of 1.
    
    Type Parameters:
    
    T - the type of the pushed elements
    
    Returns:
    
    a new ReplayProcessor that replays its last pushed element to each new Subscriber
  - cacheLastOrDefault
```
public static <T> ReplayProcessor<T> cacheLastOrDefault(@Nullable
                                                        T value)
```
    Deprecated.
    
    Create a ReplayProcessor that caches the last element it has pushed, replaying it to late subscribers. If a Subscriber comes in before any value has been pushed, then the defaultValue is emitted instead. This is a buffer-based ReplayProcessor with a history size of 1.
    
    Type Parameters:
    
    T - the type of the pushed elements
    
    Parameters:
    
    value - a default value to start the sequence with in case nothing has been cached yet.
    
    Returns:
    
    a new ReplayProcessor that replays its last pushed element to each new Subscriber, or a default one if nothing was pushed yet
  - create
```
public static <E> ReplayProcessor<E> create()
```
    Deprecated.
    
    Create a new ReplayProcessor that replays an unbounded number of elements, using a default internal Queue.
    
    Type Parameters:
    
    E - the type of the pushed elements
    
    Returns:
    
    a new ReplayProcessor that replays the whole history to each new Subscriber.
  - create
```
public static <E> ReplayProcessor<E> create(int historySize)
```
    Deprecated.
    
    Create a new ReplayProcessor that replays up to historySize elements.
    
    Type Parameters:
    
    E - the type of the pushed elements
    
    Parameters:
    
    historySize - the backlog size, ie. maximum items retained for replay.
    
    Returns:
    
    a new ReplayProcessor that replays a limited history to each new Subscriber.
  - create
```
public static <E> ReplayProcessor<E> create(int historySize,
                                            boolean unbounded)
```
    Deprecated.
    
    Create a new ReplayProcessor that either replay all the elements or a limited amount of elements depending on the unbounded parameter.
    
    Type Parameters:
    
    E - the type of the pushed elements
    
    Parameters:
    
    historySize - maximum items retained if bounded, or initial link size if unbounded
    
    unbounded - true if "unlimited" data store must be supplied
    
    Returns:
    
    a new ReplayProcessor that replays the whole history to each new Subscriber if configured as unbounded, a limited history otherwise.
  - createTimeout
```
public static <T> ReplayProcessor<T> createTimeout(Duration maxAge)
```
    Deprecated.
    
    Creates a time-bounded replay processor.
    In this setting, the ReplayProcessor internally tags each observed item with a timestamp value supplied by the Schedulers.parallel() and keeps only those whose age is less than the supplied time value converted to milliseconds. For example, an item arrives at T=0 and the max age is set to 5; at T>=5 this first item is then evicted by any subsequent item or termination signal, leaving the buffer empty.
    Once the processor is terminated, subscribers subscribing to it will receive items that remained in the buffer after the terminal signal, regardless of their age.
    If an subscriber subscribes while the ReplayProcessor is active, it will observe only those items from within the buffer that have an age less than the specified time, and each item observed thereafter, even if the buffer evicts items due to the time constraint in the mean time. In other words, once an subscriber subscribes, it observes items without gaps in the sequence except for any outdated items at the beginning of the sequence.
    Note that terminal signals (onError and onComplete) trigger eviction as well. For example, with a max age of 5, the first item is observed at T=0, then an onComplete signal arrives at T=10. If an subscriber subscribes at T=11, it will find an empty ReplayProcessor with just an onCompleted signal.
    
    Type Parameters:
    
    T - the type of items observed and emitted by the Processor
    
    Parameters:
    
    maxAge - the maximum age of the contained items
    
    Returns:
    
    a new ReplayProcessor that replays elements based on their age.
  - createTimeout
```
public static <T> ReplayProcessor<T> createTimeout(Duration maxAge,
                                                   Scheduler scheduler)
```
    Deprecated.
    
    Creates a time-bounded replay processor.
    In this setting, the ReplayProcessor internally tags each observed item with a timestamp value supplied by the Scheduler and keeps only those whose age is less than the supplied time value converted to milliseconds. For example, an item arrives at T=0 and the max age is set to 5; at T>=5 this first item is then evicted by any subsequent item or termination signal, leaving the buffer empty.
    Once the processor is terminated, subscribers subscribing to it will receive items that remained in the buffer after the terminal signal, regardless of their age.
    If an subscriber subscribes while the ReplayProcessor is active, it will observe only those items from within the buffer that have an age less than the specified time, and each item observed thereafter, even if the buffer evicts items due to the time constraint in the mean time. In other words, once an subscriber subscribes, it observes items without gaps in the sequence except for any outdated items at the beginning of the sequence.
    Note that terminal signals (onError and onComplete) trigger eviction as well. For example, with a max age of 5, the first item is observed at T=0, then an onComplete signal arrives at T=10. If an subscriber subscribes at T=11, it will find an empty ReplayProcessor with just an onCompleted signal.
    
    Type Parameters:
    
    T - the type of items observed and emitted by the Processor
    
    Parameters:
    
    maxAge - the maximum age of the contained items
    
    Returns:
    
    a new ReplayProcessor that replays elements based on their age.
  - createSizeAndTimeout
```
public static <T> ReplayProcessor<T> createSizeAndTimeout(int size,
                                                          Duration maxAge)
```
    Deprecated.
    
    Creates a time- and size-bounded replay processor.
    In this setting, the ReplayProcessor internally tags each received item with a timestamp value supplied by the Schedulers.parallel() and holds at most size items in its internal buffer. It evicts items from the start of the buffer if their age becomes less-than or equal to the supplied age in milliseconds or the buffer reaches its size limit.
    When subscribers subscribe to a terminated ReplayProcessor, they observe the items that remained in the buffer after the terminal signal, regardless of their age, but at most size items.
    If an subscriber subscribes while the ReplayProcessor is active, it will observe only those items from within the buffer that have age less than the specified time and each subsequent item, even if the buffer evicts items due to the time constraint in the mean time. In other words, once an subscriber subscribes, it observes items without gaps in the sequence except for the outdated items at the beginning of the sequence.
    Note that terminal signals (onError and onComplete) trigger eviction as well. For example, with a max age of 5, the first item is observed at T=0, then an onComplete signal arrives at T=10. If an Subscriber subscribes at T=11, it will find an empty ReplayProcessor with just an onCompleted signal.
    
    Type Parameters:
    
    T - the type of items observed and emitted by the Processor
    
    Parameters:
    
    maxAge - the maximum age of the contained items
    
    size - the maximum number of buffered items
    
    Returns:
    
    a new ReplayProcessor that replay up to size elements, but will evict them from its history based on their age.
  - createSizeAndTimeout
```
public static <T> ReplayProcessor<T> createSizeAndTimeout(int size,
                                                          Duration maxAge,
                                                          Scheduler scheduler)
```
    Deprecated.
    
    Creates a time- and size-bounded replay processor.
    In this setting, the ReplayProcessor internally tags each received item with a timestamp value supplied by the Scheduler and holds at most size items in its internal buffer. It evicts items from the start of the buffer if their age becomes less-than or equal to the supplied age in milliseconds or the buffer reaches its size limit.
    When subscribers subscribe to a terminated ReplayProcessor, they observe the items that remained in the buffer after the terminal signal, regardless of their age, but at most size items.
    If an subscriber subscribes while the ReplayProcessor is active, it will observe only those items from within the buffer that have age less than the specified time and each subsequent item, even if the buffer evicts items due to the time constraint in the mean time. In other words, once an subscriber subscribes, it observes items without gaps in the sequence except for the outdated items at the beginning of the sequence.
    Note that terminal signals (onError and onComplete) trigger eviction as well. For example, with a max age of 5, the first item is observed at T=0, then an onComplete signal arrives at T=10. If an Subscriber subscribes at T=11, it will find an empty ReplayProcessor with just an onCompleted signal.
    
    Type Parameters:
    
    T - the type of items observed and emitted by the Processor
    
    Parameters:
    
    maxAge - the maximum age of the contained items in milliseconds
    
    size - the maximum number of buffered items
    
    scheduler - the Scheduler that provides the current time
    
    Returns:
    
    a new ReplayProcessor that replay up to size elements, but will evict them from its history based on their age.
  - subscribe
```
public void subscribe(CoreSubscriber<? super T> actual)
```
    Deprecated.
    
    Description copied from class: Flux
    
    An internal Publisher.subscribe(Subscriber) that will bypass Hooks.onLastOperator(Function) pointcut.
    In addition to behave as expected by Publisher.subscribe(Subscriber) in a controlled manner, it supports direct subscribe-time Context passing.
    
    Specified by:
    
    subscribe in interface CorePublisher<T>
    
    Specified by:
    
    subscribe in class Flux<T>
    
    Parameters:
    
    actual - the Subscriber interested into the published sequence
    
    See Also:
    
    Flux.subscribe(Subscriber)
  - getError
```
@Nullable
public Throwable getError()
```
    Deprecated.
    
    Description copied from class: FluxProcessor
    
    Current error if any, default to null
    
    Overrides:
    
    getError in class FluxProcessor<T,T>
    
    Returns:
    
    Current error if any, default to null
  - scanUnsafe
```
@Nullable
public Object scanUnsafe(Scannable.Attr key)
```
    Deprecated.
    
    Description copied from interface: Scannable
    
    This method is used internally by components to define their key-value mappings in a single place. Although it is ignoring the generic type of the Scannable.Attr key, implementors should take care to return values of the correct type, and return null if no specific value is available.
    For public consumption of attributes, prefer using Scannable.scan(Attr), which will return a typed value and fall back to the key's default if the component didn't define any mapping.
    
    Specified by:
    
    scanUnsafe in interface Scannable
    
    Overrides:
    
    scanUnsafe in class FluxProcessor<T,T>
    
    Parameters:
    
    key - a Scannable.Attr to resolve for the component.
    
    Returns:
    
    the value associated to the key for that specific component, or null if none.
  - inners
```
public Stream<? extends Scannable> inners()
```
    Deprecated.
    
    Description copied from interface: Scannable
    
    Return a Stream of referenced inners (flatmap, multicast etc)
    
    Specified by:
    
    inners in interface Scannable
    
    Overrides:
    
    inners in class FluxProcessor<T,T>
    
    Returns:
    
    a Stream of referenced inners (flatmap, multicast etc)
  - downstreamCount
```
public long downstreamCount()
```
    Deprecated.
    
    Description copied from class: FluxProcessor
    
    Return the number of active Subscriber or -1 if untracked.
    
    Overrides:
    
    downstreamCount in class FluxProcessor<T,T>
    
    Returns:
    
    the number of active Subscriber or -1 if untracked
  - isTerminated
```
public boolean isTerminated()
```
    Deprecated.
    
    Description copied from class: FluxProcessor
    
    Has this upstream finished or "completed" / "failed" ?
    
    Overrides:
    
    isTerminated in class FluxProcessor<T,T>
    
    Returns:
    
    has this upstream finished or "completed" / "failed" ?
  - onSubscribe
```
public void onSubscribe(Subscription s)
```
    Deprecated.
    
    Description copied from interface: CoreSubscriber
    
    Implementors should initialize any state used by Subscriber.onNext(Object) before calling Subscription.request(long). Should further onNext related state modification occur, thread-safety will be required.
    Note that an invalid request <= 0 will not produce an onError and will simply be ignored or reported through a debug-enabled Logger.
    
    Specified by:
    
    onSubscribe in interface Subscriber<T>
    
    Specified by:
    
    onSubscribe in interface CoreSubscriber<T>
  - currentContext
```
public Context currentContext()
```
    Deprecated.
    
    Description copied from interface: CoreSubscriber
    
    Request a Context from dependent components which can include downstream operators during subscribing or a terminal Subscriber.
    
    Specified by:
    
    currentContext in interface CoreSubscriber<T>
    
    Overrides:
    
    currentContext in class FluxProcessor<T,T>
    
    Returns:
    
    a resolved context or Context.empty()
  - getPrefetch
```
public int getPrefetch()
```
    Deprecated.
    
    Description copied from class: Flux
    
    The prefetch configuration of the Flux
    
    Overrides:
    
    getPrefetch in class Flux<T>
    
    Returns:
    
    the prefetch configuration of the Flux, -1 if unspecified
  - onComplete
```
public void onComplete()
```
    Deprecated.
    
    Specified by:
    
    onComplete in interface Subscriber<T>
  - tryEmitComplete
```
public Sinks.EmitResult tryEmitComplete()
```
    Deprecated.
    
    Description copied from interface: Sinks.Many
    
    Try to terminate the sequence successfully, generating an onComplete signal. The result of the attempt is represented as an Sinks.EmitResult, which possibly indicates error cases.
    See the list of failure Sinks.EmitResult in #emitComplete(EmitFailureHandler) javadoc for an example of how each of these can be dealt with, to decide if the emit API would be a good enough fit instead.
    
    Returns:
    
    an Sinks.EmitResult, which should be checked to distinguish different possible failures
    
    See Also:
    
    Subscriber.onComplete()
  - onError
```
public void onError(Throwable throwable)
```
    Deprecated.
    
    Specified by:
    
    onError in interface Subscriber<T>
  - tryEmitError
```
public Sinks.EmitResult tryEmitError(Throwable t)
```
    Deprecated.
    
    Description copied from interface: Sinks.Many
    
    Try to fail the sequence, generating an onError signal. The result of the attempt is represented as an Sinks.EmitResult, which possibly indicates error cases.
    See the list of failure Sinks.EmitResult in #emitError(Throwable, EmitFailureHandler) javadoc for an example of how each of these can be dealt with, to decide if the emit API would be a good enough fit instead.
    
    Parameters:
    
    t - the exception to signal, not null
    
    Returns:
    
    an Sinks.EmitResult, which should be checked to distinguish different possible failures
    
    See Also:
    
    Subscriber.onError(Throwable)
  - onNext
```
public void onNext(T t)
```
    Deprecated.
    
    Specified by:
    
    onNext in interface Subscriber<T>
  - tryEmitNext
```
public Sinks.EmitResult tryEmitNext(T t)
```
    Deprecated.
    
    Description copied from interface: Sinks.Many
    
    Try emitting a non-null element, generating an onNext signal. The result of the attempt is represented as an Sinks.EmitResult, which possibly indicates error cases.
    See the list of failure Sinks.EmitResult in #emitNext(Object, EmitFailureHandler) javadoc for an example of how each of these can be dealt with, to decide if the emit API would be a good enough fit instead.
    Might throw an unchecked exception as a last resort (eg. in case of a fatal error downstream which cannot be propagated to any asynchronous handler, a bubbling exception, ...).
    
    Parameters:
    
    t - the value to emit, not null
    
    Returns:
    
    an Sinks.EmitResult, which should be checked to distinguish different possible failures
    
    See Also:
    
    Subscriber.onNext(Object)
  - currentSubscriberCount
```
public int currentSubscriberCount()
```
    Deprecated.
    
    Description copied from interface: Sinks.Many
    
    Get how many Subscribers are currently subscribed to the sink.
    This is a best effort peek at the sink state, and a subsequent attempt at emitting to the sink might still return Sinks.EmitResult.FAIL_ZERO_SUBSCRIBER where relevant. (generally in Sinks.Many.tryEmitNext(Object)). Request (and lack thereof) isn't taken into account, all registered subscribers are counted.
    
    Returns:
    
    the number of subscribers at the time of invocation
  - asFlux
```
public Flux<T> asFlux()
```
    Deprecated.
    
    Description copied from interface: Sinks.Many
    
    Return a Flux view of this sink. Every call returns the same instance.
    
    Returns:
    
    the Flux view associated to this Sinks.Many
  - isIdentityProcessor
```
protected boolean isIdentityProcessor()
```
    Deprecated.
    
    Description copied from class: FluxProcessor
    
    Return true if FluxProcessor<T, T>
    
    Overrides:
    
    isIdentityProcessor in class FluxProcessor<T,T>
    
    Returns:
    
    true if FluxProcessor<T, T>
  - emitNext
```
public void emitNext(T value,
                     Sinks.EmitFailureHandler failureHandler)
```
    Description copied from interface: Sinks.Many
    A simplified attempt at emitting a non-null element via the Sinks.Many.tryEmitNext(Object) API, generating an onNext signal. If the result of the attempt is not a success, implementations SHOULD retry the Sinks.Many.tryEmitNext(Object) call IF the provided Sinks.EmitFailureHandler returns true. Otherwise, failures are dealt with in a predefined way that might depend on the actual sink implementation (see below for the vanilla reactor-core behavior).
    Generally, Sinks.Many.tryEmitNext(Object) is preferable since it allows a custom handling of error cases, although this implies checking the returned Sinks.EmitResult and correctly acting on it. This API is intended as a good default for convenience.
    When the Sinks.EmitResult is not a success, vanilla reactor-core operators have the following behavior:
    - Sinks.EmitResult.FAIL_ZERO_SUBSCRIBER: no particular handling. should ideally discard the value but at that point there's no Subscriber from which to get a contextual discard handler.
    - Sinks.EmitResult.FAIL_OVERFLOW: discard the value (Operators.onDiscard(Object, Context)) then call Sinks.Many.emitError(Throwable, Sinks.EmitFailureHandler) with a Exceptions.failWithOverflow(String) exception.
    - Sinks.EmitResult.FAIL_CANCELLED: discard the value (Operators.onDiscard(Object, Context)).
    - Sinks.EmitResult.FAIL_TERMINATED: drop the value (Operators.onNextDropped(Object, Context)).
    - Sinks.EmitResult.FAIL_NON_SERIALIZED: throw an Sinks.EmissionException mentioning RS spec rule 1.3. Note that Sinks.unsafe() never trigger this result. It would be possible for an Sinks.EmitFailureHandler to busy-loop and optimistically wait for the contention to disappear to avoid this case for safe sinks...
    Might throw an unchecked exception as a last resort (eg. in case of a fatal error downstream which cannot be propagated to any asynchronous handler, a bubbling exception, a Sinks.EmitResult.FAIL_NON_SERIALIZED as described above, ...).
    Specified by:
    
    emitNext in interface Sinks.Many<T>
    
    Parameters:
    
    value - the value to emit, not null
    
    failureHandler - the failure handler that allows retrying failed Sinks.EmitResult.
    
    See Also:
    
    Sinks.Many.tryEmitNext(Object), Subscriber.onNext(Object)
  - emitComplete
```
public void emitComplete(Sinks.EmitFailureHandler failureHandler)
```
    Description copied from interface: Sinks.Many
    A simplified attempt at completing via the Sinks.Many.tryEmitComplete() API, generating an onComplete signal. If the result of the attempt is not a success, implementations SHOULD retry the Sinks.Many.tryEmitComplete() call IF the provided Sinks.EmitFailureHandler returns true. Otherwise, failures are dealt with in a predefined way that might depend on the actual sink implementation (see below for the vanilla reactor-core behavior).
    Generally, Sinks.Many.tryEmitComplete() is preferable since it allows a custom handling of error cases, although this implies checking the returned Sinks.EmitResult and correctly acting on it. This API is intended as a good default for convenience.
    When the Sinks.EmitResult is not a success, vanilla reactor-core operators have the following behavior:
    - Sinks.EmitResult.FAIL_OVERFLOW: irrelevant as onComplete is not driven by backpressure.
    - Sinks.EmitResult.FAIL_ZERO_SUBSCRIBER: the completion can be ignored since nobody is listening. Note that most vanilla reactor sinks never trigger this result for onComplete, replaying the terminal signal to later subscribers instead (to the exception of Sinks.UnicastSpec.onBackpressureError()).
    - Sinks.EmitResult.FAIL_CANCELLED: the completion can be ignored since nobody is interested.
    - Sinks.EmitResult.FAIL_TERMINATED: the extra completion is basically ignored since there was a previous termination signal, but there is nothing interesting to log.
    - Sinks.EmitResult.FAIL_NON_SERIALIZED: throw an Sinks.EmissionException mentioning RS spec rule 1.3. Note that Sinks.unsafe() never trigger this result. It would be possible for an Sinks.EmitFailureHandler to busy-loop and optimistically wait for the contention to disappear to avoid this case in safe sinks...
    Might throw an unchecked exception as a last resort (eg. in case of a fatal error downstream which cannot be propagated to any asynchronous handler, a bubbling exception, a Sinks.EmitResult.FAIL_NON_SERIALIZED as described above, ...).
    Specified by:
    
    emitComplete in interface Sinks.Many<T>
    
    Parameters:
    
    failureHandler - the failure handler that allows retrying failed Sinks.EmitResult.
    
    See Also:
    
    Sinks.Many.tryEmitComplete(), Subscriber.onComplete()
  - emitError
```
public void emitError(Throwable error,
                      Sinks.EmitFailureHandler failureHandler)
```
    Description copied from interface: Sinks.Many
    A simplified attempt at failing the sequence via the Sinks.Many.tryEmitError(Throwable) API, generating an onError signal. If the result of the attempt is not a success, implementations SHOULD retry the Sinks.Many.tryEmitError(Throwable) call IF the provided Sinks.EmitFailureHandler returns true. Otherwise, failures are dealt with in a predefined way that might depend on the actual sink implementation (see below for the vanilla reactor-core behavior).
    Generally, Sinks.Many.tryEmitError(Throwable) is preferable since it allows a custom handling of error cases, although this implies checking the returned Sinks.EmitResult and correctly acting on it. This API is intended as a good default for convenience.
    When the Sinks.EmitResult is not a success, vanilla reactor-core operators have the following behavior:
    - Sinks.EmitResult.FAIL_OVERFLOW: irrelevant as onError is not driven by backpressure.
    - Sinks.EmitResult.FAIL_ZERO_SUBSCRIBER: the error is ignored since nobody is listening. Note that most vanilla reactor sinks never trigger this result for onError, replaying the terminal signal to later subscribers instead (to the exception of Sinks.UnicastSpec.onBackpressureError()).
    - Sinks.EmitResult.FAIL_CANCELLED: the error can be ignored since nobody is interested.
    - Sinks.EmitResult.FAIL_TERMINATED: the error unexpectedly follows another terminal signal, so it is dropped via Operators.onErrorDropped(Throwable, Context).
    - Sinks.EmitResult.FAIL_NON_SERIALIZED: throw an Sinks.EmissionException mentioning RS spec rule 1.3. Note that Sinks.unsafe() never trigger this result. It would be possible for an Sinks.EmitFailureHandler to busy-loop and optimistically wait for the contention to disappear to avoid this case in safe sinks...
    Might throw an unchecked exception as a last resort (eg. in case of a fatal error downstream which cannot be propagated to any asynchronous handler, a bubbling exception, a Sinks.EmitResult.FAIL_NON_SERIALIZED as described above, ...).
    Specified by:
    
    emitError in interface Sinks.Many<T>
    
    Parameters:
    
    error - the exception to signal, not null
    
    failureHandler - the failure handler that allows retrying failed Sinks.EmitResult.
    
    See Also:
    
    Sinks.Many.tryEmitError(Throwable), Subscriber.onError(Throwable)

Class ReplayProcessor<T>

Nested Class Summary

Nested classes/interfaces inherited from interface reactor.core.Fuseable

Nested classes/interfaces inherited from interface reactor.core.Scannable

Nested classes/interfaces inherited from interface reactor.core.Disposable

Field Summary

Fields inherited from interface reactor.core.Fuseable

Fields inherited from interface reactor.core.Scannable

Method Summary

Methods inherited from class reactor.core.publisher.FluxProcessor

Methods inherited from class reactor.core.publisher.Flux

Methods inherited from class java.lang.Object

Methods inherited from interface reactor.core.Scannable

Methods inherited from interface org.reactivestreams.Publisher

Methods inherited from interface reactor.core.Disposable

Method Detail

cacheLast

cacheLastOrDefault

create

create

create

createTimeout

createTimeout

createSizeAndTimeout

createSizeAndTimeout

subscribe

getError

scanUnsafe

inners

downstreamCount

isTerminated

onSubscribe

currentContext

getPrefetch

onComplete

tryEmitComplete

onError

tryEmitError

onNext

tryEmitNext

currentSubscriberCount

asFlux

isIdentityProcessor

emitNext

emitComplete

emitError