Nulo/y-webrtc
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

catch errors when sending messages

Browse source
This commit is contained in:
Kevin Jahns 2019-12-11 15:50:07 +01:00
parent 8adefb1da9
commit c684411cf3
1 changed files with 6 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/y-webrtc.js
View file

@ -104,7 +104,9 @@ const readPeerMessage = (peerConn, buf) => {
*/ */
const sendWebrtcConn = (webrtcConn, encoder) => { const sendWebrtcConn = (webrtcConn, encoder) => {
log('send message to ', logging.BOLD, webrtcConn.remotePeerId, logging.UNBOLD, logging.GREY, ' (', webrtcConn.room.name, ')', logging.UNCOLOR) log('send message to ', logging.BOLD, webrtcConn.remotePeerId, logging.UNBOLD, logging.GREY, ' (', webrtcConn.room.name, ')', logging.UNCOLOR)
try {
webrtcConn.peer.send(encoding.toUint8Array(encoder)) webrtcConn.peer.send(encoding.toUint8Array(encoder))
} catch (e) {}
} }
/** /**
@ -115,7 +117,9 @@ const broadcastWebrtcConn = (room, encoder) => {
log('broadcast message in ', logging.BOLD, room.name, logging.UNBOLD) log('broadcast message in ', logging.BOLD, room.name, logging.UNBOLD)
const m = encoding.toUint8Array(encoder) const m = encoding.toUint8Array(encoder)
room.webrtcConns.forEach(conn => { room.webrtcConns.forEach(conn => {
try {
conn.peer.send(m) conn.peer.send(m)
} catch (e) {}
}) })
} }