stream

open fun stream(endpoint: NetworkEndpoint, cacheKey: CacheKey, policy: CachePolicy = CachePolicy.Default): Flow<E>

Observes the entity for endpoint/cacheKey reactively: emits the result of an initial fetch, then re-emits whenever the underlying local store reports a change for cacheKey.

The default implementation is non-reactive (it emits a single fetch); GenericRepository overrides it to follow LocalDataSource.changes.