Skip to content

Commit 4ba8610

Browse files
committed
fixes #154
Signed-off-by: Dimitris Xalatsis <dimitris_ha@hotmail.com>
1 parent 3c278ad commit 4ba8610

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

lib/sender.js

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -413,11 +413,12 @@ class FluentSender {
413413
callbacks.forEach((callback) => {
414414
this._handleEvent('error', error, callback);
415415
});
416+
} else { // no error on ack
417+
callbacks.forEach((callback) => {
418+
callback && callback();
419+
});
416420
}
417421
this._sendQueueSize -= sendPacketSize;
418-
callbacks.forEach((callback) => {
419-
callback && callback();
420-
});
421422
process.nextTick(() => {
422423
this._waitToWrite();
423424
});

0 commit comments

Comments
 (0)