WebRTC Base
This commit is contained in:
parent
17eacfcfdc
commit
5360929167
|
@ -206,17 +206,19 @@ export default class WebRTC
|
||||||
{
|
{
|
||||||
if(event.channel.label == ':default:'){
|
if(event.channel.label == ':default:'){
|
||||||
WebRTC.channels.set(this.id, this);
|
WebRTC.channels.set(this.id, this);
|
||||||
this.channel = event.channel
|
this.channel = event.channel;
|
||||||
|
event.channel.addEventListener("message",({data})=>{
|
||||||
|
let pack = JSON.parse(data);
|
||||||
|
this.emit('input', pack);
|
||||||
|
})
|
||||||
|
event.channel.addEventListener("close",()=>{
|
||||||
|
this.channel = undefined;
|
||||||
|
WebRTC.channels.delete(this.id);
|
||||||
|
WebRTC.requireGC = true;
|
||||||
|
})
|
||||||
|
}else{
|
||||||
|
this.emit('datachannel', event.channel);
|
||||||
}
|
}
|
||||||
event.channel.addEventListener("message",({data})=>{
|
|
||||||
let pack = JSON.parse(data);
|
|
||||||
this.emit('input', pack);
|
|
||||||
})
|
|
||||||
event.channel.addEventListener("close",()=>{
|
|
||||||
this.channel = undefined;
|
|
||||||
WebRTC.channels.delete(this.id);
|
|
||||||
WebRTC.requireGC = true;
|
|
||||||
})
|
|
||||||
}
|
}
|
||||||
public send(data:object)
|
public send(data:object)
|
||||||
{
|
{
|
||||||
|
|
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
Loading…
Reference in New Issue