watch method

Stream<DtoChat?> watch(
  1. ChatId id
)

Returns the Stream of real-time changes happening with the DtoChat identified by the provided id.

Implementation

Stream<DtoChat?> watch(ChatId id) {
  return stream((db) {
    final stmt = db.select(db.chats)..where((u) => u.id.equals(id.val));

    StreamController<DtoChat?>? controller = _controllers[id];
    if (controller == null) {
      controller = StreamController<DtoChat?>.broadcast(sync: true);
      _controllers[id] = controller;
    }

    DtoChat? last;

    return StreamGroup.merge([
      controller.stream,
      stmt.watch().map((e) => e.isEmpty ? null : _ChatDb.fromDb(e.first)),
    ]).asyncExpand((e) async* {
      if (e != last) {
        last = e;
        yield e;
      }
    });
  });
}