Advertisement
abhishekr

janus.js-senderStreams-receiverStreams

Mar 31st, 2021
46
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 2.30 KB | None | 0 0
  1. if(config.receiverTransforms) {
  2. var receiverStreams = null;
  3. if(RTCRtpSender.prototype.createEncodedStreams) {
  4. receiverStreams = event.receiver.createEncodedStreams();
  5. } else if(RTCRtpSender.prototype.createAudioEncodedStreams || RTCRtpSender.prototype.createEncodedVideoStreams) {
  6. if(event.track.kind === "audio" && config.receiverTransforms["audio"]) {
  7. receiverStreams = event.receiver.createEncodedAudioStreams();
  8. } else if(event.track.kind === "video" && config.receiverTransforms["video"]) {
  9. receiverStreams = event.receiver.createEncodedVideoStreams();
  10. }
  11. }
  12. if(receiverStreams) {
  13. console.log(receiverStreams);
  14. if(receiverStreams.readableStream && receiverStreams.writableStream) {
  15. receiverStreams.readableStream
  16. .pipeThrough(config.receiverTransforms[event.track.kind])
  17. .pipeTo(receiverStreams.writableStream);
  18. } else if(receiverStreams.readable && receiverStreams.writable) {
  19. receiverStreams.readable
  20. .pipeThrough(config.receiverTransforms[event.track.kind])
  21. .pipeTo(receiverStreams.writable);
  22. }
  23. }
  24. }
  25.  
  26.  
  27. // Check if insertable streams are involved
  28. if(sender && config.senderTransforms) {
  29. var senderStreams = null;
  30. if(RTCRtpSender.prototype.createEncodedStreams) {
  31. senderStreams = sender.createEncodedStreams();
  32. } else if(RTCRtpSender.prototype.createAudioEncodedStreams || RTCRtpSender.prototype.createEncodedVideoStreams) {
  33. if(sender.track.kind === "audio" && config.senderTransforms["audio"]) {
  34. senderStreams = sender.createEncodedAudioStreams();
  35. } else if(sender.track.kind === "video" && config.senderTransforms["video"]) {
  36. senderStreams = sender.createEncodedVideoStreams();
  37. }
  38. }
  39. if(senderStreams) {
  40. console.log(senderStreams);
  41. if(senderStreams.readableStream && senderStreams.writableStream) {
  42. senderStreams.readableStream
  43. .pipeThrough(config.senderTransforms[sender.track.kind])
  44. .pipeTo(senderStreams.writableStream);
  45. } else if(senderStreams.readable && senderStreams.writable) {
  46. senderStreams.readable
  47. .pipeThrough(config.senderTransforms[sender.track.kind])
  48. .pipeTo(senderStreams.writable);
  49. }
  50. }
  51. }
  52.  
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement