@syncot/connection
Advanced tools
Comparing version 0.0.12 to 0.0.13
@@ -256,3 +256,5 @@ import { createDisconnectedError, createDuplicateIdError, createInvalidEntityError, createInvalidStreamError, createNoServiceError, } from '@syncot/error'; | ||
for (const stream of streams.values()) { | ||
stream.destroy(error); | ||
if (stream.destroyed !== true) { | ||
stream.destroy(error); | ||
} | ||
} | ||
@@ -259,0 +261,0 @@ streams.clear(); |
@@ -1,2 +0,2 @@ | ||
import { SyncOtEmitter } from '@syncot/util'; | ||
import { EmitterInterface, SyncOtEmitter } from '@syncot/util'; | ||
import { Connection } from './connection'; | ||
@@ -16,3 +16,3 @@ import { StreamFactory } from './factory'; | ||
*/ | ||
export interface StreamManager extends SyncOtEmitter<StreamManagerEvents> { | ||
export interface StreamManager extends EmitterInterface<SyncOtEmitter<StreamManagerEvents>> { | ||
} | ||
@@ -19,0 +19,0 @@ /** |
{ | ||
"name": "@syncot/connection", | ||
"version": "0.0.12", | ||
"version": "0.0.13", | ||
"description": "An RPC library for communication over Duplex object streams.", | ||
@@ -31,4 +31,4 @@ "keywords": [ | ||
"@syncot/error": "^0.0.6", | ||
"@syncot/util": "^0.0.7", | ||
"@types/node": "^10.12.21", | ||
"@syncot/util": "^0.0.8", | ||
"@types/node": "^12.0.4", | ||
"@types/readable-stream": "^2.3.1", | ||
@@ -38,3 +38,3 @@ "readable-stream": "^3.3.0", | ||
}, | ||
"gitHead": "f42e7403c10d1236587af99fc13d35b2a27a55ad" | ||
"gitHead": "888dd1570ed3023173b3b5bbafad0f29271b246f" | ||
} |
37968
937
+ Added@syncot/util@0.0.8(transitive)
+ Added@types/node@12.20.55(transitive)
- Removed@syncot/util@0.0.7(transitive)
- Removed@types/node@10.17.60(transitive)
Updated@syncot/util@^0.0.8
Updated@types/node@^12.0.4