A promise that resolves when the operation is complete.
Throws
If an error occurs during the process of retrieving producers.
Example
constoptions = { 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}`); }, }, };
Retrieves piped producers and signals new consumer transport for each retrieved producer.
Param: options
The options for getting piped producers.
Param: options.nsock
The WebSocket instance used for communication.
Param: options.islevel
A flag indicating the level of the operation.
Param: options.parameters
Additional parameters for the operation.
Param: options.parameters.member
The member identifier.
Param: options.parameters.signalNewConsumerTransport
The function to signal new consumer transport.
Returns
A promise that resolves when the operation is complete.
Throws
If an error occurs during the process of retrieving producers.
Example