Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- if(config.receiverTransforms) {
- var receiverStreams = null;
- if(RTCRtpSender.prototype.createEncodedStreams) {
- receiverStreams = event.receiver.createEncodedStreams();
- } else if(RTCRtpSender.prototype.createAudioEncodedStreams || RTCRtpSender.prototype.createEncodedVideoStreams) {
- if(event.track.kind === "audio" && config.receiverTransforms["audio"]) {
- receiverStreams = event.receiver.createEncodedAudioStreams();
- } else if(event.track.kind === "video" && config.receiverTransforms["video"]) {
- receiverStreams = event.receiver.createEncodedVideoStreams();
- }
- }
- if(receiverStreams) {
- console.log(receiverStreams);
- if(receiverStreams.readableStream && receiverStreams.writableStream) {
- receiverStreams.readableStream
- .pipeThrough(config.receiverTransforms[event.track.kind])
- .pipeTo(receiverStreams.writableStream);
- } else if(receiverStreams.readable && receiverStreams.writable) {
- receiverStreams.readable
- .pipeThrough(config.receiverTransforms[event.track.kind])
- .pipeTo(receiverStreams.writable);
- }
- }
- }
- // Check if insertable streams are involved
- if(sender && config.senderTransforms) {
- var senderStreams = null;
- if(RTCRtpSender.prototype.createEncodedStreams) {
- senderStreams = sender.createEncodedStreams();
- } else if(RTCRtpSender.prototype.createAudioEncodedStreams || RTCRtpSender.prototype.createEncodedVideoStreams) {
- if(sender.track.kind === "audio" && config.senderTransforms["audio"]) {
- senderStreams = sender.createEncodedAudioStreams();
- } else if(sender.track.kind === "video" && config.senderTransforms["video"]) {
- senderStreams = sender.createEncodedVideoStreams();
- }
- }
- if(senderStreams) {
- console.log(senderStreams);
- if(senderStreams.readableStream && senderStreams.writableStream) {
- senderStreams.readableStream
- .pipeThrough(config.senderTransforms[sender.track.kind])
- .pipeTo(senderStreams.writableStream);
- } else if(senderStreams.readable && senderStreams.writable) {
- senderStreams.readable
- .pipeThrough(config.senderTransforms[sender.track.kind])
- .pipeTo(senderStreams.writable);
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement