datasourcex-util/com.caplin.integration.datasourcex.util.flow/VersionedMapEvent

VersionedMapEvent

sealed interface VersionedMapEvent<out K : Any, out V : Any>(source)

A map mutation carrying the version it was written at, for distribution to consumers that gate on version >. Unlike MapEvent there is no old value and no Populated marker: the stream is delta-only and current values are read from the store.

Inheritors

Upsert

Removed

Types

Removed

class Removed<out K : Any>(val key: K, val version: Long) : VersionedMapEvent<K, Nothing>

Upsert

class Upsert<out K : Any, out V : Any>(val key: K, val value: V, val version: Long) : VersionedMapEvent<K, V>

Properties

key

abstract val key: K

version

abstract val version: Long