@syncot/connection
Advanced tools
Comparing version 0.0.7 to 0.0.8
@@ -347,2 +347,3 @@ import { createDisconnectedError, createDuplicateIdError, createInvalidEntityError, createInvalidStreamError, createNoServiceError, } from '@syncot/error'; | ||
const onData = (data) => { | ||
/* istanbul ignore else */ | ||
if (this.stream === stream && | ||
@@ -360,2 +361,3 @@ data != null) { | ||
const onEnd = () => { | ||
/* istanbul ignore else */ | ||
if (this.stream === stream) { | ||
@@ -444,2 +446,3 @@ this.send({ | ||
const serviceStream = serviceStreams.get(message.id); | ||
/* istanbul ignore else */ | ||
if (serviceStream) { | ||
@@ -452,2 +455,3 @@ serviceStream.write(message.data); | ||
const serviceStream = serviceStreams.get(message.id); | ||
/* istanbul ignore else */ | ||
if (serviceStream) { | ||
@@ -495,2 +499,3 @@ serviceStream.end(); | ||
final: (callback) => { | ||
/* istanbul ignore else */ | ||
if (this.stream === stream) { | ||
@@ -510,2 +515,3 @@ this.send({ | ||
write: (data, _encoding, callback) => { | ||
/* istanbul ignore else */ | ||
if (this.stream === stream && data != null) { | ||
@@ -542,2 +548,3 @@ this.send({ | ||
const serviceStream = proxyStreams.get(message.id); | ||
/* istanbul ignore else */ | ||
if (serviceStream) { | ||
@@ -550,2 +557,3 @@ serviceStream.push(message.data); | ||
const serviceStream = proxyStreams.get(message.id); | ||
/* istanbul ignore else */ | ||
if (serviceStream) { | ||
@@ -552,0 +560,0 @@ serviceStream.push(null); |
export * from './connection'; | ||
export * from './factory'; | ||
export * from './manager'; |
export * from './connection'; | ||
export * from './factory'; | ||
export * from './manager'; |
{ | ||
"name": "@syncot/connection", | ||
"version": "0.0.7", | ||
"version": "0.0.8", | ||
"description": "An RPC library for communication over Duplex object streams.", | ||
@@ -29,3 +29,3 @@ "keywords": [ | ||
"dependencies": { | ||
"@syncot/error": "^0.0.4", | ||
"@syncot/error": "^0.0.5", | ||
"@syncot/util": "^0.0.5", | ||
@@ -37,3 +37,3 @@ "@types/node": "^10.12.21", | ||
}, | ||
"gitHead": "5fd7d4343e2c3c6e047f338feabea25d672444c3" | ||
"gitHead": "8de3f7bbee6695ec65937da8b8bbdbe9c867b996" | ||
} |
37572
10
930
+ Added@syncot/error@0.0.5(transitive)
- Removed@syncot/error@0.0.4(transitive)
Updated@syncot/error@^0.0.5