Interface IStash<T>

Stateful component that allows to stash elements until needed. You get duplicate detection and ordering guarantees.

public interface IStash<T>

Properties

The waiting element with maximum sequence number.

T MaxSeqWaiting { get; }

The waiting element with minimum sequence number.

T MinSeqWaiting { get; }

Add an item to stash. (When using the resequencer as kind of a stash for elements).

void AddStash(T item)

Clear waiting (out-of-sequence) elements.

void ClearWaiting()

Get the out-of-sequence elements that are still waiting.

ReadOnlyCollection<T> GetWaiting()

How to resolve a duplicate. (seq_number, old, fresh) => replacement element

event Func<long, T, T, T> OnDuplicate