Catch queue processing error

Author: Dudeplayz

clients/soa/js/src/peer/webrtc-connection.ts

@@ -168,7 +168,7 @@ export class WebRTCPeerConnection extends TypedEmitter<PeerConnectionEvents> imp
 
   async handleSignalingMessage(msg: SignalingMessage) {
     this.signalingQueue.push(msg as RTCSignalingMessage);
-    await this.executeQueue();
+    this.executeQueue().catch(err => { if(err) throw err });
   }
 
   private async executeQueue() {

clients/soa_services/electricalConnection/js/src/service.ts

@@ -114,7 +114,7 @@ export class ElectricalConnectionService extends TypedEmitter<ElectricalConnecti
           channel.send(JSON.stringify(packet));
         });
         await channel.ready();
-        this.queue.start();
+        this.queue.start().catch(err => { if(err) throw err });
       });
 
       // find the bus set or create a new one