RTCForge API Reference v1.1.1
    Preparing search index...

    Server-side (mediasoup SFU) representation of a Producer being delivered to a consuming peer. Created paused; call MediaEntity.resume (or MediaRouter.resumeConsumer) once the client transport is ready. Closes automatically when its source producer closes.

    Hierarchy (View Summary)

    Index

    Constructors

    • Parameters

      • peerId: string

        Id of the peer receiving this stream.

      • producerId: string

        Id of the source producer being consumed.

      • consumer: Consumer

        The underlying mediasoup consumer to wrap.

      Returns Consumer

    Properties

    _entity: MediaEntityHandle

    The wrapped mediasoup producer/consumer handle.

    peerId: string

    Id of the peer this entity belongs to.

    producerId: string

    Id of the source Producer this consumer receives from.

    role: "consumer" = ...

    Always "consumer".

    Accessors

    • get closed(): boolean

      Whether the entity has been closed.

      Returns boolean

    • get paused(): boolean

      Whether the entity is currently paused.

      Returns boolean

    • get rtpParameters(): RtpParameters

      RTP parameters the client needs to receive and decode this consumer.

      Returns RtpParameters

    Methods

    • Synchronously invokes every listener registered for event, in registration order.

      Type Parameters

      • K extends keyof MediaEntityEvents

      Parameters

      • event: K

        The event name to emit.

      • ...args: MediaEntityEvents[K]

        The argument tuple to pass to each listener, matching Events[event].

      Returns boolean

      true if at least one listener was invoked, false if there were none.

      The listener list is snapshotted before dispatch, so mutations made by handlers take effect only on subsequent emissions. Listeners are isolated: if one throws, the remaining listeners still run and the error is surfaced via console.error rather than swallowed silently (consistent with LocalMessageBus).

    • Returns the number of listeners currently registered for event.

      Type Parameters

      • K extends keyof MediaEntityEvents

      Parameters

      • event: K

        The event name to count listeners for.

      Returns number

      The count of registered listeners (0 if none).

    • Removes a previously registered listener for event.

      Type Parameters

      • K extends keyof MediaEntityEvents

      Parameters

      • event: K

        The event name the listener was registered for.

      • listener: (...args: MediaEntityEvents[K]) => void

        The exact function reference passed to on or once.

      Returns this

      This emitter, for chaining.

      If the listener is not currently registered, this is a no-op. Only the first matching registration is removed.

    • Registers a listener that is invoked every time event is emitted.

      Type Parameters

      • K extends keyof MediaEntityEvents

      Parameters

      • event: K

        The event name to listen for.

      • listener: (...args: MediaEntityEvents[K]) => void

        Callback invoked with the event's argument tuple.

      Returns this

      This emitter, for chaining.

    • Registers a listener that is invoked at most once: it is removed automatically before being called the first time event is emitted.

      Type Parameters

      • K extends keyof MediaEntityEvents

      Parameters

      • event: K

        The event name to listen for.

      • listener: (...args: MediaEntityEvents[K]) => void

        Callback invoked with the event's argument tuple on the next emission.

      Returns this

      This emitter, for chaining.

      Remove a pending one-time listener by passing the same function reference to off.

    • Removes listeners for a single event, or for all events.

      Parameters

      • Optionalevent: keyof MediaEntityEvents

        The event name to clear; if omitted, listeners for every event are removed.

      Returns this

      This emitter, for chaining.