jsonMessages property

Stream<Map<String, dynamic>> get jsonMessages

Incoming application JSON payloads (excludes session handshake and text).

Implementation

Stream<Map<String, dynamic>> get jsonMessages => messagesStream
    .where(
      (PeerMessage message) =>
          !PeerMessageTypes.isSessionType(message.type) &&
          message.type != PeerMessageTypes.appText,
    )
    .map(
      (PeerMessage message) => message.payload ?? const <String, dynamic>{},
    );