@playlive/realtime-pipeline
    Preparing search index...

    Function processMessage

    • Parse a raw WebSocket frame and dispatch it into the pipeline store.

      Invalid JSON, error envelopes without a type field, and unknown message types are silently dropped (matching the legacy behavior). The function never throws — failures are logged via options.log when provided.

      Parameters

      Returns void

      import { createPipelineStore } from "@playlive/realtime-pipeline/store";
      import { processMessage } from "@playlive/realtime-pipeline/connection";

      const store = createPipelineStore();
      processMessage(store, '{"type":"tick","id":"1","sourceType":"tiltify","data":{…}}');