WatchQuery<R, F extends Fields> extension Observe and inspect

Re-executes a root database query after relevant committed changes.

on

• Query<R, F>

Methods

watch({Iterable<TableSchema> reads = const [], ExecutionOptions options = const ExecutionOptions()}) → Stream<List<R>>

Available on Query<R, F>, provided by the WatchQuery extension

Initial snapshot followed by fresh snapshots after relevant committed writes. Add tables hidden inside raw SQL with reads. Read errors are emitted without closing the stream, allowing a later invalidation to retry the query.