parseODIDMessageStream function

Stream<ParseResult<ODIDMessage>> parseODIDMessageStream(
  1. Stream<Uint8List> messageStream
)

Stream (using parseODIDMessage).

Implementation

Stream<ParseResult> parseODIDMessageStream(Stream<Uint8List> messageStream) =>
    messageStream
        .map(tryParseODIDMessage)
        .where((r) => r != null)
        .cast<ParseResult>();