watchSingle method
Creates an auto-updating stream of this statement, similar to
watch. However, it is assumed that the query will only emit
one result, so instead of returning a Stream<List<D>>, this returns a
Stream<D>. If, at any point, the query emits no or more than one rows,
an error will be added to the stream instead.
Uses the distinct flag to ensure that only distinct rows are returned
Implementation
@override
Stream<DT> watchSingle() =>
$state.copyWith(distinct: true).buildSelectStatement().watchSingle();