watchSingle<T extends Table, D> method

  1. @override
Stream<D?> watchSingle<T extends Table, D>(
  1. Expression<bool> filter(
    1. T
    )
)
override

Implementation

@override
Stream<D?> watchSingle<T extends Table, D>(
  Expression<bool> Function(T) filter,
) {
  try {
    final table = _getTable<T, D>();
    return (_database.select(table)..where(filter)).watchSingleOrNull();
  } catch (e) {
    throw DatabaseBridgeException(error: e);
  }
}