Merge pull request #14 from jfromaniello/allow_changing_drain

allow changing the drain property in the receiver
amqp · Oct 22, 2018 · 209d5a5 · 209d5a5
2 parents fc1f796 + e26c76c
commit 209d5a5
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/lib/receiver.ts b/lib/receiver.ts
@@ -61,6 +61,10 @@ export class Receiver extends Link {
     return (this._link as RheaReceiver).drain;
   }
 
+  set drain(value: boolean) {
+    (this._link as RheaReceiver).drain = value;
+  }
+
   addCredit(credit: number): void {
     (this._link as RheaReceiver).add_credit(credit);
   }