处理流时的异步操作

Question

我需要一些帮助，

我需要将文件作为流读取，并且在第一个块上我需要创建一个异步操作的数据库表。所以我想做的是创建一个双工/变压器流，它会在我们处理文件的开头时创建表，但在其他方面作为普通流工作。

作为一个伪代码，我认为是这样的

fileLoaderService
  .loadfileAsStream()
  .pipe(parser)
  .pipe(
    if !headerProcessed
      createTable
    passThrough 
  )
  .pipe(insertToTable)

这可能吗？

Answer 1

您可以使用ReadableStream控制器的start函数在pull处理流之前执行任务

let stream = new ReadableStream({
  start(controller) {
     // create table
  },
  pull(controller) {
     // enqueue next chunk
  }
})