filterODIDMessageStream function

Stream<ODIDMessage?> filterODIDMessageStream(
  1. Stream<ODIDMessage?> messageStream
)

Filters out ODIDMessage with invalid, corrupted or incomplete data.

Implementation

Stream<ODIDMessage?> filterODIDMessageStream(
  Stream<ODIDMessage?> messageStream,
) => messageStream.map(
  (message) => validateODIDMessage(message) ? message : null,
);