watchPendingMessages method

Stream<List<Message>> watchPendingMessages()

Watches all pending messages (not yet synced to any peer).

Implementation

Stream<List<Message>> watchPendingMessages() {
  return (select(messages)
        ..where(
            (t) => t.status.equals(MessageStatus.pending.value)))
      .watch();
}