Class GetProducersPiped

Retrieves piped producers and signals new consumer transport for each retrieved producer.

The options for getting piped producers.

The WebSocket instance used for communication.

A flag indicating the level of the operation.

Additional parameters for the operation.

The member identifier.

The function to signal new consumer transport.

A promise that resolves when the operation is complete.

If an error occurs during the process of retrieving producers.

const options = {
nsock: socketInstance,
islevel: '2',
parameters: {
member: 'user123',
signalNewConsumerTransport: async ({ remoteProducerId, islevel, nsock, parameters }) => {
// Implementation to signal new consumer transport
console.log(`Signaling new consumer transport for producer: ${remoteProducerId}`);
},
},
};

const getProducersPipedService = new GetProducersPiped();
await getProducersPipedService.getProducersPiped(options);
console.log('Piped producers retrieved successfully.');

Constructors

Methods

Constructors

Methods

  • Retrieves piped producers and signals new consumer transport for each retrieved producer.

    Parameters

    Returns Promise<void>

    A promise that resolves when the operation is complete.

    If an error occurs during the process of retrieving producers.