|
@@ -4,6 +4,7 @@ import Heartbeat from "./Heartbeat.js"
|
|
|
|
|
|
export default class Rtcp extends EventEmitter {
|
|
|
constructor(e) {
|
|
|
+
|
|
|
super();
|
|
|
E(this, "connection", null);
|
|
|
E(this, "inputChannel", null);
|
|
@@ -145,8 +146,8 @@ export default class Rtcp extends EventEmitter {
|
|
|
const e = Date.now();
|
|
|
this.connection.ondatachannel = t=>{
|
|
|
logger.info(`ondatachannel: ${t.channel.label}`);
|
|
|
+
|
|
|
this.inputChannel = t.channel;
|
|
|
-
|
|
|
this.inputChannel.onopen = ()=>{
|
|
|
var r;
|
|
|
logger.info("The input channel has opened, id:", (r = this.inputChannel) == null ? void 0 : r.id),
|
|
@@ -162,14 +163,16 @@ export default class Rtcp extends EventEmitter {
|
|
|
startTime: e,
|
|
|
group: "joinRoom"
|
|
|
}))
|
|
|
+ console.log('this.inputChannel',this.inputChannel)
|
|
|
}
|
|
|
,
|
|
|
this.inputChannel.onclose = ()=>{
|
|
|
var r;
|
|
|
return logger.info("The input channel has closed, id:", (r = this.inputChannel) == null ? void 0 : r.id)
|
|
|
- }
|
|
|
- ,
|
|
|
+ },
|
|
|
this.inputChannel.onmessage = r=>{
|
|
|
+ // console.log('this.workers',this.workers)
|
|
|
+ console.log('inputChannel',r.data)
|
|
|
this.workers.dataHandle(r.data)
|
|
|
}
|
|
|
}
|