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