IAkavacheConnection interface¶

Summary¶

Abstracts the database connection used by SQLite-backed blob caches. The surface is intentionally narrow and CacheEntry-specific so that implementations can bind parameters and cache prepared statements without going through reflection or an expression-tree translator.

classDiagram
class IAkavacheConnection
class IDisposable {
    <>
}
IDisposable <|.. IAkavacheConnection

Implements: IDisposable

Remarks¶

Every method returns IObservable rather than Task — this matches the observable-first shape of IBlobCache so the whole sqlite pipeline composes directly with Rx operators without Task/await bridges. Cancellation is expressed through subscription disposal: unsubscribing before an operation completes is the observable-native "cancel" signal. Note that operations already dequeued by the worker thread cannot be cancelled mid-sqlite3_step — SQLite has no per-statement cancel primitive.

Single-value reads (Get, TryReadLegacyV10Value, TableExists) emit exactly one value and then complete. Multi-value reads (GetMany, GetAll, GetAllKeys) emit one item per matching row and then complete; callers that want a materialized list can apply .ToList() at the boundary. Writers (Upsert, Invalidate, SetExpiry, etc.) emit a single Unit and then complete on success or OnError on failure.

Task-returning adapters live on IAkavacheConnectionTaskExtensions for callers that prefer async/await at the boundary — those are thin ToTask wrappers that do not take part in the hot path.

Methods¶