ts = new ConcurrentTransform({
          transform: function(chunk, encoding, callback) {
            callback(null, chunk);
          },
          flush: function(callback) {