Fixes issue winstonjs#1194

lib/winston/transports/file.js

@@ -51,7 +51,6 @@ var File = module.exports = function (options) {
   //
   // Bind this context for listener functions
   //
-  this._onDrain = this._onDrain.bind(this);
   this._onError = this._onError.bind(this);
 
   if (options.filename || options.dirname) {
@@ -90,7 +89,6 @@ var File = module.exports = function (options) {
   this._size     = 0;
   this._created  = 0;
   this._drains   = 0;
-  this._next     = noop;
   this._opening  = false;
 
   this.open();
@@ -152,12 +150,23 @@ File.prototype.log = function (info, callback) {
     self._endStream(function () { self._nextFile(); });
   }
 
-  var written = this._stream.write(output, logged);
-  if (written === false) ++this._drains;
-  if (!this._drains) callback(); // eslint-disable-line
-  else this._next = callback;
+  if (self._drains > 0) {
+    self._stream.once('drain', function () {
+      self._drains--;
+      return self.log(info, callback);
+    });
+    return;
+  }
 
-  return written;
+  var shouldContinue = self._stream.write(output, logged);
+
+  if (!shouldContinue) {
+    self._drains++;
+  }
+
+  callback();
+
+  return shouldContinue;
 };
 
 //
@@ -391,26 +400,17 @@ File.prototype._needsNewFile = function (size) {
   return this.maxsize && size >= this.maxsize;
 };
 
-File.prototype._onDrain = function onDrain() {
-  if (--this._drains) return;
-  var next = this._next;
-  this._next = noop;
-  next();
-};
-
 File.prototype._onError = function onError(err) {
   this.emit('error', err);
 };
 
 File.prototype._setupStream = function (stream) {
   stream.on('error', this._onError);
-  stream.on('drain', this._onDrain);
   return stream;
 };
 
 File.prototype._cleanupStream = function (stream) {
   stream.removeListener('error', this._onError);
-  stream.removeListener('drain', this._onDrain);
   return stream;
 };
 
@@ -448,7 +448,6 @@ File.prototype._createStream = function () {
       // TODO: what should we do with errors here?
       debug(err);
     })
-    .on('drain', this._onDrain)
     .on('open', function () {
       debug('file open ok', fullpath);
       self.emit('open');