Tag: stream

在Node.js上从Web Audio API播放PCMstream: 我使用networkingaudioAPI从浏览器stream式传输录制的PCMaudio。我将它与binaryJS（websocket连接）stream到一个nodejs服务器，我试图播放该stream使用扬声器npm模块在服务器上。这是我的客户。 audio缓冲器首先是非交织的IEEE 32位线性PCM，标称范围在-1和+1之间。我从两个PCM通道中的一个开始，并在下面进行stream式处理。 var client = new BinaryClient('ws://localhost:9000'); var Stream = client.send(); recorder.onaudioprocess = function(AudioBuffer){ var leftChannel = AudioBuffer.inputBuffer.getChannelData (0); Stream.write(leftChannel); } 现在我接收到数据作为缓冲区，并尝试将其写入npm包中的扬声器对象。 var Speaker = require('speaker'); var speaker = new Speaker({ channels: 1, // 1 channel bitDepth: 32, // 32-bit samples sampleRate: 48000, // 48,000 Hz sample rate signed:true }); […]

如何与node.jsstream中的<File>对象进行交互？: 我正在使用gulp来构build一个glob匹配的文件stream，并将它们的嵌套结构全部移动到一个新的位置。要做到这一点，我首先想build立一个简单的“通过”stream，看看我通过从gulp.src（）pipe道通过。这是我的testinggulpfile.js： var through = require("through"); var fs = require("fs"); function write(file) { console.log(file); console.log(file.toString()); } gulp.task("move", function () { return gulp.src("./**") .pipe(through(write)); }); 如果我在命令行上运行gulp'move'任务，我得到的输出如下所示： <File "some/path"> [object Object] <File "some/path/file.js" <Buffer 2f 2a 0a 0a 4f 72 67 69 6e 61 6c 20 53 74 79 6c 65 20 66 72 6f 6d […]

如何使用请求模块缓冲http响应？: 我会转换一个传入的http响应，这是一个stream，并将数据存储在一个variables中。我对节点stream没有太多的了解，我正在努力做到这一点。 var request = require('request'); request('http://google.com/doodle.png', function (error, response, body) { // buffer the stream response to and a string variable. }) UPDATE 这是我的完整代码。我的目标是获取请求的图像，并将其存储在mongodb中。但是图像总是被损坏。我以为因为请求响应是一个stream，图像只被部分保存，因此腐败。 request('http://google.com/doodle.png', function (error, response, body) { image = new Buffer(body, 'binary'); db.images.insert({ filename: 'google.png', imgData: image}, function (err) { // handle errors etc. }); }) 现在你已经澄清了请求缓冲区的反应，我怎样才能妥善保存图像没有腐败的任何想法。

Node.js控制stream：callback或承诺？: 我知道有很多node.js的控制stream库。其中一些使用callback函数（如async，asyncblock等）来实现一个asynchronous函数，其他使用promise概念（Q，延期，期货等）。由于长时间运行的脚本会一个接一个地执行一系列可能会失败的操作，您更喜欢哪个控制stream程？为什么？优缺点都有什么？

什么是node.js最好的控制stream模块？: 我已经使用了caolan的asynchronous模块，这是非常好的，但是跟踪错误和通过控制stream传递数据的不同方式导致开发有时是非常困难的。我想知道是否有更好的select，或目前在生产环境中使用什么。谢谢阅读。

我应该如何从Java应用程序运行NodeJS？: 我正在编写一个Java库，实际上是一个Clojure库，但是对于这个问题，重要的是它在JVM上运行。这个库需要执行一些JavaScript。我尝试过与Nashorn，但我遇到一些限制，可能太难以克服。作为替代，我想尝试NodeJS。我希望自己的库是独立的，不依赖于独立运行NodeJS的系统，因此需要特定的部署机制将Java和NodeJS工件放置在正确的位置，由两个不同的networking服务器提取。但是这种方法带来了一些问题。我将通过HTTP与NodeJS通话，但是我不希望NodeJS打开特定的端口。我想find一个随机的未使用的，所以没有碰撞。我也想控制从NodeJS的日志去，以保持与我的应用程序的其余部分。最后，我的应用程序应该能够检测到NodeJS何时崩溃并重新运行它或报告错误的信息。什么是最好的方法来解决这个问题？有没有任何Java库可以帮助用这种方式pipe理subprocess？特别是我应该从NodeJS方面做的任何事情（我对NodeJS很陌生，以前从未使用过）。

pipestream到s3.upload（）: 我目前正在使用名为s3-upload-stream的node.js插件将非常大的文件传输到Amazon S3。它使用多部分API，大部分它工作得很好。但是，这个模块正在显示其年龄，我已经不得不对其进行修改（作者也不赞同）。今天我遇到了亚马逊的另一个问题，我真的想采取作者的build议，并开始使用官方aws-sdk来完成我的上传。但。官方的SDK似乎不支持pipe道到s3.upload() 。 s3.upload的本质是你必须将可读stream作为parameter passing给S3构造函数。我有大约120多个用户代码模块进行各种文件处理，他们不知道他们输出的最终目的地。引擎递给他们一个可移动的可写入输出stream，然后他们将其传送给它。我不能给他们一个AWS.S3对象，并要求他们调用upload()而不向所有模块添加代码。我使用s3-upload-stream的原因是因为它支持pipe道。有没有办法使aws-sdk s3.upload()东西，我可以pipestream的？

dynamic创build并将zip压缩到客户端: 我正在使用NodeJs（w / express），我正尝试将一个zip文件传回客户端。 zip中包含的文件不在文件系统中，而是dynamic创build。我想将文件内容传输到压缩文件，然后将压缩文件传输回客户端。 IE我希望客户端收到： tmp.zip –> 1.txt –> 2.txt –> 3.txt 其中1,2,3.txt是dynamic创build的，并stream式传输到zip文件。这可能吗？

NodeJS：双工stream和变换stream有什么区别？: Stream文档声明Duplex Streams是实现Readable和Writable接口的stream，而Transform Streams是Duplexstream，输出是以某种方式从input中计算出来的。不幸的是，文档没有描述什么变换stream提供超出双工stream。两者有什么区别？你什么时候使用一个？

可以pipe到console.log吗？: 我正在学习node.js。我想了解溪stream和pipe道。是否有可能将http请求的响应传递给console.log？我知道如何通过将处理程序绑定到数据事件来完成此任务，但我更感兴趣将其传输到控制台。 http.get(url, function(response) { response.pipe(console.log); response.on('end', function() { console.log('finished'); }); }); 谢谢