EventProcessingHistory

In-memory event storage, used to check if an event was already dealt with and avoid duplication. i.e. present in both pending and live sources.

All operations are thread-safe.

Constructors

constructor()

suspend fun add(event: Event): Boolean

Adds an event to the end of this storage.

suspend fun clear()

Clears the storage, removes every previously added Event.

Clears the whole storage if this event is the one added most recently.

suspend fun contains(event: Event): Boolean

suspend fun remove(event: Event): Boolean

Removes the event from this storage if present.