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): <Error class: unknown class>

Adds an event to the end of this storage.

suspend fun clear(): <Error class: unknown class>

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): <Error class: unknown class>

Removes the event from this storage if present.