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