The options for getting piped producers.
A promise that resolves when the operation is complete.
const options = {
nsock: socketInstance,
islevel: '1',
parameters: {
member: 'memberId',
signalNewConsumerTransport: async ({ remoteProducerId, islevel, nsock, parameters }) => {
// Implementation for signaling new consumer transport
},
},
};
getProducersPiped(options)
.then(() => {
console.log('Successfully retrieved piped producers');
})
.catch((error) => {
console.error('Error retrieving piped producers:', error);
});
Retrieves piped producers and signals new consumer transport for each retrieved producer.