node.js-stream相关内容

gulp中vinyl-buffer和gulp-streamify的目的是什么?

正如文档所说，它们都处理将非流插件转换为流. 我试图理解的是，如果我可以在某物上使用 .pipe() 方法，这不就意味着它是一个流吗? 如果是这样，我应该在这里转换成什么? vinyl-source-stream 示例: (来自:https://www.npmjs.com/package/vinyl-buffer) var browserify = require('br ..
发布时间：2022-01-12 13:40:53 前端开发

Node.js 将相同的可读流传送到多个(可写)目标中

我需要连续运行两个需要从同一个流中读取数据的命令.将一个流通过管道传输到另一个流后，缓冲区被清空，因此我无法再次从该流中读取数据，因此这不起作用: var spawn = require('child_process').spawn;var fs = require('fs');var request = require('request');var inputStream = request( ..
发布时间：2021-12-01 22:33:59 前端开发

节点js文件系统:不为可读流调用结束事件

我正在尝试提取 .tar 文件(从目录中打包)，然后检查提取目录中文件的名称.我正在使用 tar-fs 来提取 tar 文件，然后使用 fs.createReadStream 来操作数据.这是我到目前为止所得到的: fs.createReadStream(req.files.file.path).pipe(tar.extract(req.files.file.path + '0')).on('错 ..
发布时间：2021-09-04 19:28:57 其他开发

检查流是否为process.stdout

是否有一种优雅的方法来确定流是否为process.stdout 我正在使用流，并且希望结束流，但是发现如果流是process.stdout，则会抛出错误，因为process.stdout是我尝试使用try and catch，但是process.stdout错误结束了节点进程，忽略了try and catch. 解决方案 也许这对我来说太幼稚了，但我认为您可以使用!==进行检查: ..
发布时间：2020-07-01 19:29:51 前端开发

使用带有请求包和功能pipe()的Node.js服务器吗?

此刻，我正在使用Node.js服务器来模拟后端.该服务器是一个网络服务器，并在不同的请求上返回json对象，工作完美无缺.现在，我必须从另一个域获取json对象，因此必须代理服务器.我在npm中找到了一个名为 request 的软件包.我可以使用简单的示例来工作，但必须转发整个网页. 我的代理代码如下: var $express = require('express'), $http ..
发布时间：2020-07-01 19:29:46 其他开发

单流多次消费

我想知道是否有可能多个功能可以消耗node.js中的单个流.如果是，怎么办?是否可以通过管道传输到多个目的地? 我想在两个并行的不同函数中使用流.我正在使用异步模块进行并行流.那么是否可以说在这些函数中的每个函数中发出pipe()语句? 谢谢. 解决方案 是，这是可能的，容易的和常见的.以下是从单个源到多个源的管道数据流.它向您展示了一个放置在事件循环中的匿名回调函数，该函数包 ..
发布时间：2020-07-01 19:28:34 其他开发

如何将节点CLI程序的输出通过管道传输到Shell?

我基本上想做这样的事情: $ my-node-cli | less 请注意，less仅是示例.我需要它与任何其他* nix命令一起使用. 有关用例的更多信息: 我编写了一个节点CLI程序包，该程序包搜索一些在线资源并将结果输出到Shell.由于结果集可能非常庞大，因此客户希望对它进行其他操作，例如grep，head，tail，tee，...等等. ..
发布时间：2020-07-01 19:28:31 其他开发

如何在node.js中使用MTOM SOAP Web服务?

我需要从node.js中基于soap的Web服务下载或处理文件. 有人可以建议我如何在node.js中处理此问题 我尝试使用"node-soap"或"soap" NPM模块.它适用于普通的肥皂网络服务.但是，不适用于二进制流或基于MTOM的SOAP Web服务 解决方案 我想尝试回答这个问题……有趣的是2年零2个月后，我无法弄清楚如何轻松解决同一问题 我正在尝试从以下响应中获取 ..
发布时间：2020-07-01 19:28:29 其他开发

如何在NodeJS中模拟流

我正在尝试对大量处理流的node-js模块之一进行单元测试.我正在尝试模拟流(我将要写入的流)，因为在我的模块中，我想触发".on('data/end)"侦听器.本质上，我希望能够执行以下操作: var mockedStream = new require('stream').readable(); mockedStream.on('data', function withData('da ..
发布时间：2020-07-01 19:27:26 其他开发

如何实现可写流

我想将数据从亚马逊运动流传输到s3日志或Bunyan日志. 该示例适用于文件写入流或stdout.我将如何伪造自己的可写流? //this works var file = fs.createWriteStream('my.log') kinesisSource.pipe(file) 这表示没有方法“开"，这是行不通的 var stream = {}; //process.s ..
发布时间：2020-05-18 02:12:52 其他开发

从两个管道流创建Node.js流

如果可能的话，我想通过管道将两个Node.js流合并为一个.我正在使用转换流. 换句话说，我希望我的图书馆返回myStream供人们使用.例如，他们可以写: process.stdin.pipe(myStream).pipe(process.stdout); 在内部，我使用的是第三方vendorStream，它可以完成一些工作，并插入到myInternalStream中包含的我自 ..
发布时间：2020-05-18 02:01:18 其他开发

Node.js:将流内容拆分为n个部分

我试图了解节点流及其生命周期.因此，我想将流的内容分为n部分.下面的代码仅用于解释我的意图，并表明我已经尝试过一些自己的事情.我省略了一些细节 我有一个流，它仅生成一些数据(只是一个数字序列): class Stream extends Readable { constructor() { super({objectMode: true, highWaterMark: 1} ..
发布时间：2020-05-18 01:48:40 前端开发