2.0.3

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@pushrocks/smartproxy",
-  "version": "2.0.2",
+  "version": "2.0.3",
   "lockfileVersion": 1,
   "requires": true,
   "dependencies": {

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pushrocks/smartproxy",
-  "version": "2.0.2",
+  "version": "2.0.3",
   "private": false,
   "description": "a proxy for handling high workloads of proxying",
   "main": "dist/index.js",

ts/smartproxy.portproxy.ts

@@ -24,8 +24,13 @@ const portProxyCalls = {
           host: 'localhost',
           port: 8001
         });
-        from.pipe(to);
-        to.pipe(from);
+        from.pipe(to)
+        to.pipe(from)
+        from.on('error', () => { from.end(), to.end() });
+        to.on('error', () => { from.end(), to.end() });
+        from.on('close', () => {
+          to.end();
+        })
       })
       .listen(portArg);
     console.log(`PortProxy -> OK: Now listening on port ${portArg}`);