Comparing version 2.0.2 to 2.0.3
@@ -370,2 +370,9 @@ /* | ||
}; | ||
Receiver.prototype.drain_credit = function() { | ||
this.drain = true; | ||
this.issue_flow = true; | ||
this.connection._register(); | ||
}; | ||
Receiver.prototype.add_credit = Receiver.prototype.flow;//alias | ||
@@ -372,0 +379,0 @@ Receiver.prototype._get_drain = function () { |
{ | ||
"name": "rhea", | ||
"version": "2.0.2", | ||
"version": "2.0.3", | ||
"description": "reactive AMQP 1.0 library", | ||
@@ -5,0 +5,0 @@ "homepage": "http://github.com/amqp/rhea", |
@@ -85,2 +85,3 @@ /// <reference types="node" /> | ||
add_credit(credit: number): void; | ||
drain_credit(): void; | ||
set_credit_window(credit_window: number): void; | ||
@@ -87,0 +88,0 @@ } |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
893246
14199