bare-rpc - npm Package Compare versions

Comparing version 1.3.5 to 1.3.6

index.js

@@ -67,2 +67,10 @@ const safetyCatch = require('safety-catch')
   _sendMessage(message, cb) {
+    // Once the underlying stream is being torn down there is nowhere left to
+    // write, so drop the message and settle the callback immediately. This
+    // keeps stream teardown from stalling on a drain that will never arrive.
+    if (this._stream.destroying) {
+      if (cb) cb(null)
+      return
+    }
+
     const header = c.encode(m.header, message)
@@ -173,3 +181,36 @@
 
-    // TODO Destroy pending requests and responses
+    // Reject any request awaiting a plain reply. Requests whose response is
+    // delivered over a stream are torn down through that stream below.
+    for (const request of this._outgoingRequests.values()) {
+      if (request.received && request._responseStream === null) request._reject(err)
+    }
+
+    // Collect the streams first, deduplicating as a single request may appear
+    // in more than one map, then destroy them once the maps have been cleared.
+    const streams = new Set()
+
+    for (const request of this._outgoingRequests.values()) {
+      if (request._requestStream !== null) streams.add(request._requestStream)
+    }
+
+    for (const request of this._incomingRequests.values()) {
+      if (request._requestStream !== null) streams.add(request._requestStream)
+    }
+
+    for (const request of this._outgoingResponses.values()) {
+      if (request._responseStream !== null) streams.add(request._responseStream)
+    }
+
+    for (const request of this._incomingResponses.values()) {
+      if (request._responseStream !== null) streams.add(request._responseStream)
+    }
+
+    this._outgoingRequests.clear()
+    this._outgoingResponses.clear()
+    this._incomingRequests.clear()
+    this._incomingResponses.clear()
+    this._pendingRequests.clear()
+    this._pendingResponses.clear()
+
+    for (const stream of streams) stream.destroy(err)
   }
@@ -176,0 +217,0 @@

package.json

 {
   "name": "bare-rpc",
-  "version": "1.3.5",
+  "version": "1.3.6",
   "description": "librpc ABI compatible RPC for Bare",
@@ -5,0 +5,0 @@ "exports": {

No alert changes

Improved metrics

Total package byte prevSize

46919

3.56%

Lines of code

988

3.46%

No dependency changes