如何保证Node的流写入器的执行顺序？

const { pipeline } = require('stream');

pipeline(
  writableStream1,
  writableStream2,
  writableStream3,
  (err) => {
    if (err) {
      console.error('Pipeline failed.', err);
    } else {
      console.log('Pipeline succeeded.');
    }
  }
);

const async = require('async');

const queue = async.queue((task, callback) => {
  // 执行写入器的逻辑
  task(callback);
}, 1); // 并发数为1，保证顺序执行

queue.push((callback) => {
  // 写入器1的逻辑
  callback();
});

queue.push((callback) => {
  // 写入器2的逻辑
  callback();
});

queue.push((callback) => {
  // 写入器3的逻辑
  callback();
});

const write1 = () => {
  return new Promise((resolve, reject) => {
    // 写入器1的逻辑
    resolve();
  });
};

const write2 = () => {
  return new Promise((resolve, reject) => {
    // 写入器2的逻辑
    resolve();
  });
};

const write3 = () => {
  return new Promise((resolve, reject) => {
    // 写入器3的逻辑
    resolve();
  });
};

write1()
  .then(() => write2())
  .then(() => write3())
  .catch((err) => {
    console.error('Error:', err);
  });