Tweak channel buffering.

mtth · Mar 12, 2017 · 18db3b4 · 18db3b4
1 parent 142b9a3
commit 18db3b4
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/lib/services.js b/lib/services.js
@@ -603,6 +603,9 @@ Client.prototype._emitMessage$ = function (wreq, opts, cb) {
     if (this._buffering$) {
       debug('no active client channels, buffering call');
       this.once('channel', function () {
+        // We restrict buffering to startup, otherwise we risk silently
+        // hiding errors (especially since channel timeouts don't apply yet).
+        this._buffering$ = false;
         this._emitMessage$(wreq, opts, cb);
       });
     } else {

diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "avsc",
-  "version": "5.0.0-rc.23",
+  "version": "5.0.0-rc.24",
   "description": "Avro for JavaScript",
   "homepage": "https://github.com/mtth/avsc",
   "keywords": [