Comparing version 0.3.3 to 0.3.4
@@ -393,2 +393,5 @@ /* | ||
if (d && !d.remote_settled) { | ||
if (fields.state && fields.state !== d.remote_state) { | ||
d.remote_state = message.unwrap_outcome(fields.state); | ||
} | ||
if (fields.settled) { | ||
@@ -395,0 +398,0 @@ d.remote_settled = fields.settled; |
@@ -36,3 +36,3 @@ /* | ||
Transport.prototype.has_writes_pending = function () { | ||
return this.pending.length > 0; | ||
return this.pending.length > 0 || !this.header_sent; | ||
}; | ||
@@ -39,0 +39,0 @@ |
{ | ||
"name": "rhea", | ||
"version": "0.3.3", | ||
"version": "0.3.4", | ||
"description": "reactive AMQP 1.0 library", | ||
@@ -5,0 +5,0 @@ "homepage": "http://github.com/amqp/rhea", |
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
971872
15320