如何创建一个流来接收和累积数据，同时将数据传递给 nodejs 中的另一个流

大佬教程收集整理的这篇文章主要介绍了如何创建一个流来接收和累积数据，同时将数据传递给 nodejs 中的另一个流，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。

如何解决如何创建一个流来接收和累积数据，同时将数据传递给 nodejs 中的另一个流？

我正在尝试创建一个双向流（我相信它被称为转换流）。流将从 http 请求接收数据，存储数据，并将相同的数据传递给另一个流（在本例中，http.ServerResponse 又名 res）。

这是一个代码示例来演示这个想法：

import http from "http";

export default function handler(req,res) {
    // awk@R_944_10225@ pseudocode
    let data = [];
    let transform = new Stream();
    transform.on('data',chunk => {
        data.push(chunk);
        res.pushToStream(chunk);
    })
    transform.on('end',() => {
        res.end();
        console.log('got data: ',data)
    })
    // end awk@R_944_10225@ pseudocode
    const mapReq = http.request(`http://map.service.example.com/foo-bar`,(mapRes) => transform.pipe(res));
    mapReq.end();
}

解决方法

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

app.get("/test",function (req,res) {
    const pass = new PassThrough();
    const data = [];
    pass.on('data',(chunk) => {
        data.push(chunk)
    });
    pass.on('end',() => {
        console.log('got data: ',data)
    })
    http.request(`http://jsonplaceholder.typicode.com/users`,(responsE) => {
        response.pipe(pass).pipe(res);
    }).end();
});

大佬总结

以上是大佬教程为你收集整理的如何创建一个流来接收和累积数据，同时将数据传递给 nodejs 中的另一个流全部内容，希望文章能够帮你解决如何创建一个流来接收和累积数据，同时将数据传递给 nodejs 中的另一个流所遇到的程序开发问题。

如果觉得大佬教程网站内容还不错，欢迎将大佬教程推荐给程序员好友。

本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。