diff --git a/index.js b/index.js index 77329e4..f28fc82 100644 --- a/index.js +++ b/index.js @@ -54,9 +54,9 @@ ParallelTransform.prototype._transform = function(chunk, enc, callback) { return; } if (self._ordered) { - self._buffer.put(pos, (data === undefined || data === null) ? null : data); + self._buffer.put(pos, data == null ? null : data); } - else { + else if ( data != null ) { self._buffer.push(data); } self._drain();