public static interface Sinks.MulticastReplaySpec
Subscriber| Modifier and Type | Method and Description |
|---|---|
<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.
Backpressure : this sink honors downstream demand of individual subscribers.
Replaying: all elements pushed to this sink are replayed to new subscribers.
|
<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.
Backpressure : this sink honors downstream demand of individual subscribers.
Replaying: all elements pushed to this sink are replayed to new subscribers.
|
<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.
Backpressure : this sink honors downstream demand of individual subscribers.
Replaying: the latest element pushed to this sink is replayed to new subscribers. |
<T> Sinks.Many<T> |
limit(Duration maxAge)
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(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,
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,
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.historySize - maximum number of elements able to replayed<T> Sinks.Many<T> limit(Duration maxAge)
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.maxAge - maximum retention time for elements to be retained<T> Sinks.Many<T> limit(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, 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.historySize - maximum number of elements able to replayedmaxAge - maximum retention time for elements to be retained<T> Sinks.Many<T> limit(int historySize, 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.historySize - maximum number of elements able to replayedmaxAge - maximum retention time for elements to be retainedscheduler - a Scheduler to derive the time from