when link closes, settle any incomplete transfer

amqp · Sep 18, 2019 · 24d6098 · 24d6098
1 parent 998e767
commit 24d6098
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/lib/link.js b/lib/link.js
@@ -153,6 +153,9 @@ link.prefix_event = function (event) {
 
 link.on_detach = function (frame) {
     if (this.state.remote_closed()) {
+        if (this._incomplete) {
+            this._incomplete.settled = true;
+        }
         this.remote.detach = frame.performative;
         var error = this.remote.detach.error;
         if (error) {

diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
     "name": "rhea",
-    "version": "1.0.9",
+    "version": "1.0.10",
     "description": "reactive AMQP 1.0 library",
     "homepage": "http://github.com/amqp/rhea",
     "license": "Apache-2.0",