cache/io.github.maniramezan.kenwork.cache/InMemoryCache

InMemoryCache

class InMemoryCache<V : Any>(maxSize: Int? = null, currentTimeMillis: () -> Long = System::currentTimeMillis) : TimestampedCache<V>

An in-memory TimestampedCache with optional LRU eviction.

Mirrors SwiftyNetwork's InMemoryCache. State is guarded by a Mutex (the Kotlin analog of the Swift actor), and storage uses an access-ordered LinkedHashMap so reads promote entries to most-recently-used. When maxSize is set, the least-recently-used entries are evicted once the limit is exceeded.

Mutations are published to changes so reactive consumers can observe the cache; reads (which only reorder for LRU) do not emit.

Parameters

maxSize

maximum number of entries to retain, or null for unbounded. Must not be negative.

currentTimeMillis

time source, injectable for deterministic tests.

Constructors

InMemoryCache

constructor(maxSize: Int? = null, currentTimeMillis: () -> Long = System::currentTimeMillis)

Functions

changes

open override fun changes(): Flow<CacheChange>

A hot stream of CacheChanges for this cache. The default is an empty flow, so caches that cannot observe mutations are simply non-reactive; observable caches override this.

count

suspend fun count(): Int

The current number of entries.

entry