pub fn read_rrd_streams_from_file_or_stdin(
    version_policy: VersionPolicy,
    paths: &[String]
) -> (Receiver<Result<LogMsg>>, Receiver<u64>)
Expand description

Asynchronously decodes potentially multiplexed RRD streams from the given paths, or standard input if none are specified.

This function returns 2 channels:

  • The first channel contains both the successfully decoded data, if any, as well as any errors faced during processing.
  • The second channel, which will fire only once, after all processing is done, indicates the total number of bytes processed.

This function is best-effort: it will try to make progress even in the face of errors. It is up to the user to decide whether and when to stop.

This function is capable of decoding multiple independent recordings from a single stream.