有条件地调用 GulpJS 任务（手动）

Question

我想构建一个 gulp 任务，它会在运行之前有条件地手动调用其他一些任务。在看到 gulp.run('task') 已被弃用后，我最终得到了这个基本结构：

const build = {
    server: () => {
        return gulp.src(files.server)
            ...
            .pipe(gulp.dest(files.outDir))
    },

    web: () => {
        return gulp.src(files.web)
            ...
            .pipe(gulp.dest(files.outDir))
    }
}

gulp.task('serve', () => {
    // run the server and if necessary, force it to stop first
    const start = () => expressServer.start('./dist/main.js')

    // don't try to run if build hasn't been run first
    try {
        fs.statSync('./dist/main.js') // throws an exception if the file doesn't exist
        start()
    } catch (err) {
        // ----- TODO in parallel; build server and web
        // afterwards; run server iff there were no errors

        if (failed)
            console.error(err)
        else
            start()
    }
})

看起来调用 build.server() 或 build.web() 确实会运行 gulp 任务，但函数会立即返回 - 我猜这意味着这些函数的主体是异步运行的？

谁能帮我理解：

• gulp.src(...). ... .gulp.dest(...) 链实际上返回了什么？我怀疑 gulp 是否异步运行这些操作？
• 假设异步操作；我该如何等待这些完成？
• 如果不是异步的，我该如何执行它们？

Answer 1

我发现DefinitelyTyped (Typescript) 文件通常有助于弄清楚发生了什么。据我所知：

• The gulp.src function 将提供NodeJS.ReadWriteStream；
• The node.d.ts file 有点难以理解，但基本上所有 ...Streams 都有一个 pipe 方法，它接收一个流并返回一个相同/相似 (?) 类型。

所以基本上，您返回gulp.src 的结果（管道位不会改变返回值的类型），它是一个节点 流。

这基本上意味着您可以运行server 和web 任务，并仅在它们成功完成后使用finish callbacks of the streams those tasks return 采取行动。

作为脚注，虽然我不熟悉确切的工作原理，但如果您需要等待多个流完成，我认为merge-stream 也可能会有所帮助。

---

这是一个基本示例（基于您的代码，减去 try..catch 位）：

var gulp = require("gulp");
var mergeStream = require("merge-stream");

const build = {
  server: () => {
    process.stdout.write("MYMESSAGE: Server...\n");
    return gulp.src("src/nonexistent/server.js").pipe(gulp.dest("./build/server"));
  },
  web: () => {
    process.stdout.write("MYMESSAGE: Web...\n");
    return gulp.src("src/web.js").pipe(gulp.dest("./build/server"));
  }
}

gulp.task("serve", () => {
  const start = () => process.stdout.write("MYMESSAGE: Starting!\n");

  try {
    throw new Error("Simulated error!");
  } catch(err) {
    // In parallel build server and web, afterwards run
    // server iff there were no erros.
    mergeStream(build.server(), build.web())
      .on("error", () => console.error(err))
      .on("finish", () => start());    
  }
});