Interface LiveObjectSource

Push-oriented live object feed. Wraps a ReadableStream plus lightweight event subscription helpers. Implementations advance largestLocation monotonically as objects arrive.

interface LiveObjectSource {
    largestLocation: undefined | Location;
    stream: ReadableStream<MoqtObject>;
    onDone(listener: () => void): () => void;
    onNewObject(listener: (obj: MoqtObject) => void): () => void;
    stop(): void;
}

Implemented by

LiveTrackSource

Index

Properties

largestLocation stream

Methods

onDone onNewObject stop

Properties

`Readonly`largestLocation

largestLocation: undefined | Location

Highest (latest) location observed so far; undefined until first object

`Readonly`stream

stream: ReadableStream<MoqtObject>

Continuous stream yielding objects as they are produced

Methods

onDone

onDone(listener: () => void): () => void
Register a listener invoked when the live stream ends (normal or error). Returns an unsubscribe function.
Parameters
- listener: () => void
Returns () => void
- Defined in libs/moqtail-ts/src/client/track/content_source.ts:34

onNewObject

onNewObject(listener: (obj: MoqtObject) => void): () => void
Register a listener invoked (async) for each new object. Returns an unsubscribe function.
Parameters
- listener: (obj: MoqtObject) => void
Returns () => void
- Defined in libs/moqtail-ts/src/client/track/content_source.ts:32

stop

stop(): void
Stop ingestion and release underlying reader (idempotent).

Returns void
- Defined in libs/moqtail-ts/src/client/track/content_source.ts:36