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