watchDirectMessages method

Stream<List<Message>> watchDirectMessages(
  1. String peerId,
  2. String localId
)

Watches direct messages between the local node and a specific peer. Includes messages sent BY local TO peer, and BY peer TO local.

Implementation

Stream<List<Message>> watchDirectMessages(String peerId, String localId) {
  return (select(messages)
        ..where((t) =>
            (t.senderId.equals(localId) & t.targetId.equals(peerId)) |
            (t.senderId.equals(peerId) & t.targetId.equals(localId)))
        ..orderBy([(t) => OrderingTerm.asc(t.createdAt)]))
      .watch();
}