[fix] #1116 Do not start a new stream with a WS2P connection which is not connected yet

app/lib/streams/WS2PStreamer.ts

@@ -32,6 +32,7 @@ export class WS2PStreamer extends stream.Transform {
       }
     } catch (e) {
       logger.warn('WS2P >> Streamer >>', e)
+      this.ws2pc.close()
     }
     done && done();
   }

app/modules/ws2p/lib/WS2PClient.ts

@@ -22,9 +22,15 @@ export class WS2PClient {
       },
       expectedPub
     )
-    // Streaming
     const streamer = new WS2PStreamer(c)
+    c.connected
+      .then(() => {
+        // Streaming
         server.pipe(streamer)
+      })
+      .catch(() => {
+        server.unpipe(streamer)
+      })
     c.closed.then(() => {
       server.unpipe(streamer)
     })