watchIncomingMessages method

Stream<List<Message>> watchIncomingMessages(
  1. String localNodeId
)

Watches all messages addressed to the local node or broadcast.

This is useful for a unified inbox view.

Implementation

Stream<List<Message>> watchIncomingMessages(String localNodeId) {
  return (select(messages)
        ..where((t) =>
            t.targetId.equals(localNodeId) | t.targetId.equals('*'))
        ..orderBy([(t) => OrderingTerm.asc(t.createdAt)]))
      .watch();
}