watch<P, R extends Record> abstract method

Stream<SafeResultSet<R>> watch<P, R extends Record>(
  1. Query<P, R> query, {
  2. P? params,
  3. Duration throttle = const Duration(milliseconds: 30),
  4. Iterable<String>? triggerOnTables,
})

Reactively watches a query for changes. NOTE: This is only supported on the main database connection, not in transactions.

Implementation

Stream<SafeResultSet<R>> watch<P, R extends Record>(
  Query<P, R> query, {
  P? params,
  Duration throttle = const Duration(milliseconds: 30),
  Iterable<String>? triggerOnTables,
});