Class McapStreamReader

A streaming reader for MCAP files.

Usage example:

const reader = new McapStreamReader();
stream.on("data", (data) => {
  try {
    reader.append(data);
    for (let record; (record = reader.nextRecord()); ) {
      // process available records
    }
  } catch (e) {
    // handle errors
  }
});

Hierarchy

  • McapStreamReader

Constructors

constructor

Properties

#buffer #channelsById #decompressHandlers #doneReading #generator #includeChunks #noMagicPrefix #validateCrcs

Methods

#read append bytesRemaining done nextRecord

Constructors

constructor

Properties

Private #buffer

#buffer: default = ...

Private #channelsById

#channelsById: Map<number, Channel & {
    type: "Channel";
}> = ...

Private #decompressHandlers

#decompressHandlers: DecompressHandlers

Private #doneReading

#doneReading: boolean = false

Private #generator

#generator: Generator<undefined | TypedMcapRecord, undefined | TypedMcapRecord, void> = ...

Private #includeChunks

#includeChunks: boolean

Private #noMagicPrefix

#noMagicPrefix: boolean

Private #validateCrcs

#validateCrcs: boolean

Methods

Private #read

append

  • Provide the reader with newly received bytes for it to process. After calling this function, call nextRecord() again to parse any records that are now available.

    Parameters

    • data: Uint8Array

    Returns void

bytesRemaining

  • Returns number

    The number of bytes that have been received by append() but not yet parsed.

done

  • Returns boolean

    True if a valid, complete mcap file has been parsed.

nextRecord

  • Read the next record from the stream if possible. If not enough data is available to parse a complete record, or if the reading has terminated with a valid footer, returns undefined.

    This function may throw any errors encountered during parsing. If an error is thrown, the reader is in an unspecified state and should no longer be used.

    Returns undefined | TypedMcapRecord

Settings

Member Visibility

Theme

On This Page

Generated using TypeDoc