管道响应流后无数据

Question

使用 Electron 的 net 模块，目的是获取资源，并在收到响应后将其通过管道传输到可写流，如下所示：

const stream = await fetchResource('someUrl');
stream.pipe(fs.createWriteStream('./someFilepath'));

fetchResource的简化实现如下：

import { net } from 'electron';

async function fetchResource(url) {
  return new Promise((resolve, reject) => {
    const data = [];

    const request = net.request(url);
    request.on('response', response => {
      response.on('data', chunk => {
        data.push(chunk);
      });
      response.on('end', () => {
        // Maybe do some other stuff with data...
      });
      // Return the response to then pipe...
      resolve(response);
    });
    request.end();
  });
}

响应最终是 IncomingMessage 的一个实例，它根据节点 docs 实现了一个 Readable Stream 接口，因此它应该能够通过管道传输到一个写入流。

主要问题是最终在流中没有数据通过管道传输？？？？

Answer 1

回答我自己的问题，但问题来自多个来源：已解决的承诺和 'data' 事件。事件侦听器源在已解决的 Promise 到达之前刷新了所有数据。

一种解决方案是将流分叉到一个新的流中，如果不止一次源尝试从它进行管道传输，则该流不会与原始流竞争。

import stream from 'stream';

// ...make a request and get a response stream, then fork the stream...
const streamToResolve = response.pipe(new stream.PassThrough());

// Listen to events on response and pipe from it
// ...

// Resolve streamToResolve and separately pipe from it
// ...