kvs-core/com.santimattius.kvs.internal/KvsStream

KvsStream

interface KvsStream

Internal contract for reactive (Flow-based) read operations on a key-value store.

This interface is part of the KvsStorage internal API. It is NOT intended for direct use by library consumers. Stability is NOT guaranteed across versions.

Each method returns a cold Flow that emits the current value immediately on collection and subsequently emits a new value whenever the underlying entry changes.

See also

Inheritors

Functions

abstract fun getAllAsStream(): Flow<Map<String, Any>>

Returns a Flow that emits the full store snapshot on every change.

getBooleanAsStream

abstract fun getBooleanAsStream(key: String, defValue: Boolean): Flow<Boolean>

Returns a Flow of the Boolean value stored under key.

getFloatAsStream

abstract fun getFloatAsStream(key: String, defValue: Float): Flow<Float>

Returns a Flow of the Float value stored under key.

abstract fun getIntAsStream(key: String, defValue: Int): Flow<Int>

Returns a Flow of the Int value stored under key.

getLongAsStream

abstract fun getLongAsStream(key: String, defValue: Long): Flow<Long>

Returns a Flow of the Long value stored under key.

getStringAsStream

abstract fun getStringAsStream(key: String, defValue: String): Flow<String>

Returns a Flow of the String value stored under key.