+8
-2
@@ -259,3 +259,3 @@ const safetyCatch = require('safety-catch') | ||
| if (stream._pendingOpen === null) { | ||
| if (stream === null || stream._pendingOpen === null) { | ||
| this._pendingRequests.add(message.id) | ||
@@ -273,3 +273,3 @@ return | ||
| if (stream._pendingOpen === null) { | ||
| if (stream === null || stream._pendingOpen === null) { | ||
| this._pendingResponses.add(message.id) | ||
@@ -302,2 +302,3 @@ return | ||
| if (stream === null) return | ||
| if (message.error) stream.destroy(message.error) | ||
@@ -324,2 +325,3 @@ else stream.push(null) | ||
| if (stream === null) return | ||
| stream.cork() | ||
@@ -345,2 +347,3 @@ } | ||
| if (stream === null) return | ||
| stream.uncork() | ||
@@ -366,2 +369,3 @@ } | ||
| if (stream === null) return | ||
| if (stream.push(message.data) === false) { | ||
@@ -395,2 +399,3 @@ this._sendMessage({ | ||
| if (stream === null) return | ||
| stream.push(null) | ||
@@ -416,2 +421,3 @@ } | ||
| if (stream === null) return | ||
| stream.destroy(message.error) | ||
@@ -418,0 +424,0 @@ } |
+1
-1
| { | ||
| "name": "bare-rpc", | ||
| "version": "1.3.1", | ||
| "version": "1.3.2", | ||
| "description": "librpc ABI compatible RPC for Bare", | ||
@@ -5,0 +5,0 @@ "exports": { |
43821
0.53%922
0.66%