fix: batch sending stops

Fixes #196
jwalton · Dec 29, 2021 · 6a5b589 · 6a5b589
1 parent 4d60664
commit 6a5b589
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/ChannelWrapper.ts b/src/ChannelWrapper.ts
@@ -699,10 +699,10 @@ export default class ChannelWrapper extends EventEmitter {
             // If we didn't send all the messages, send some more...
             if (this._channelHasRoom && this._messages.length > 0) {
                 setImmediate(() => this._publishQueuedMessages(workerNumber));
+            } else {
+                this._working = false;
             }
 
-            this._working = false;
-
             /* istanbul ignore next */
         } catch (err) {
             this._working = false;