public static interface Sinks.MulticastReplaySpec
Subscriber| 限定符和类型 | 方法和说明 |
|---|---|
<T> Sinks.Many<T> |
all()
A
Sinks.Many with the following characteristics:
Multicast
Without Subscriber: all elements pushed to this sink are remembered,
even when there is no subscriber. |
<T> Sinks.Many<T> |
all(int batchSize)
A
Sinks.Many with the following characteristics:
Multicast
Without Subscriber: all elements pushed to this sink are remembered,
even when there is no subscriber. |
<T> Sinks.Many<T> |
latest()
A
Sinks.Many with the following characteristics:
Multicast
Without Subscriber: the latest element pushed to this sink are remembered,
even when there is no subscriber. |
<T> Sinks.Many<T> |
latestOrDefault(T value)
A
Sinks.Many with the following characteristics:
Multicast
Without Subscriber: the latest element pushed to this sink are remembered,
even when there is no subscriber. |
<T> Sinks.Many<T> |
limit(java.time.Duration maxAge)
A
Sinks.Many with the following characteristics:
Multicast
Without Subscriber: all elements pushed to this sink are remembered until their maxAge is reached,
even when there is no subscriber. |
<T> Sinks.Many<T> |
limit(java.time.Duration maxAge,
Scheduler scheduler)
A
Sinks.Many with the following characteristics:
Multicast
Without Subscriber: all elements pushed to this sink are remembered until their maxAge is reached,
even when there is no subscriber. |
<T> Sinks.Many<T> |
limit(int historySize)
A
Sinks.Many with the following characteristics:
Multicast
Without Subscriber: up to historySize elements pushed to this sink are remembered,
even when there is no subscriber. |
<T> Sinks.Many<T> |
limit(int historySize,
java.time.Duration maxAge)
A
Sinks.Many with the following characteristics:
Multicast
Without Subscriber: up to historySize elements pushed to this sink are remembered,
until their maxAge is reached, even when there is no subscriber. |
<T> Sinks.Many<T> |
limit(int historySize,
java.time.Duration maxAge,
Scheduler scheduler)
A
Sinks.Many with the following characteristics:
Multicast
Without Subscriber: up to historySize elements pushed to this sink are remembered,
until their maxAge is reached, even when there is no subscriber. |
<T> Sinks.Many<T> all()
Sinks.Many with the following characteristics:
Subscriber: all elements pushed to this sink are remembered,
even when there is no subscriber.<T> Sinks.Many<T> all(int batchSize)
Sinks.Many with the following characteristics:
Subscriber: all elements pushed to this sink are remembered,
even when there is no subscriber.batchSize - the underlying buffer will optimize storage by linked arrays of given size<T> Sinks.Many<T> latest()
Sinks.Many with the following characteristics:
Subscriber: the latest element pushed to this sink are remembered,
even when there is no subscriber. Older elements are discarded<T> Sinks.Many<T> latestOrDefault(T value)
Sinks.Many with the following characteristics:
Subscriber: the latest element pushed to this sink are remembered,
even when there is no subscriber.value - default value if there is no latest element to replay<T> Sinks.Many<T> limit(int historySize)
Sinks.Many with the following characteristics:
Subscriber: up to historySize elements pushed to this sink are remembered,
even when there is no subscriber. Older elements are discardedhistorySize elements pushed to this sink are replayed to new subscribers.
Older elements are discarded.
Note that though historySize of zero is forbidden, the desired equivalent effect can usually be achieved
with the Duration based variant: limit(Duration.ZERO).
historySize - maximum number of elements able to replayed, strictly positive<T> Sinks.Many<T> limit(java.time.Duration maxAge)
Sinks.Many with the following characteristics:
Subscriber: all elements pushed to this sink are remembered until their maxAge is reached,
even when there is no subscriber. Older elements are discardedhistorySize elements pushed to this sink are replayed to new subscribers.
Older elements are discarded.maxAge - maximum retention time for elements to be retained<T> Sinks.Many<T> limit(java.time.Duration maxAge, Scheduler scheduler)
Sinks.Many with the following characteristics:
Subscriber: all elements pushed to this sink are remembered until their maxAge is reached,
even when there is no subscriber. Older elements are discardedhistorySize elements pushed to this sink are replayed to new subscribers.
Older elements are discarded.maxAge - maximum retention time for elements to be retainedscheduler - a Scheduler to derive the time from<T> Sinks.Many<T> limit(int historySize, java.time.Duration maxAge)
Sinks.Many with the following characteristics:
Subscriber: up to historySize elements pushed to this sink are remembered,
until their maxAge is reached, even when there is no subscriber. Older elements are discardedhistorySize elements pushed to this sink are replayed to new subscribers.
Older elements are discarded.
Note that though historySize of zero is forbidden, the desired equivalent effect can usually be achieved
by setting the maxAge to Duration.ZERO.
historySize - maximum number of elements able to replayed, strictly positivemaxAge - maximum retention time for elements to be retained<T> Sinks.Many<T> limit(int historySize, java.time.Duration maxAge, Scheduler scheduler)
Sinks.Many with the following characteristics:
Subscriber: up to historySize elements pushed to this sink are remembered,
until their maxAge is reached, even when there is no subscriber. Older elements are discarded.historySize elements pushed to this sink are replayed to new subscribers.
Older elements are discarded.
Note that though historySize of zero is forbidden, the desired equivalent effect can usually be achieved
by setting the maxAge to Duration.ZERO.
historySize - maximum number of elements able to replayed, strictly positivemaxAge - maximum retention time for elements to be retainedscheduler - a Scheduler to derive the time from