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-reads cacheKey whenever the underlying local store reports a change. Intermediate values may be conflated; unchanged values are not emitted by GenericRepository.

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