- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时,我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
我正在尝试发送一个(巨大)文件,每秒传递的数据量有限(使用 TooTallNate/node-throttle ):
var fs = require('fs');
var Throttle = require('throttle');
var throttle = new Throttle(64);
throttle.on('data', function(data){
console.log('send', data.length);
res.write(data);
});
throttle.on('end', function() {
console.log('error',arguments);
res.end();
});
var stream = fs.createReadStream(filePath).pipe(throttle);
如果我在客户端浏览器取消下载,流将继续,直到完全传输。
我还使用 npm node-throttled-stream 测试了上面的场景,相同的行为。
如果浏览器关闭了请求,如何取消流?
<小时/>我可以通过使用获取连接close
事件
req.connection.on('close',function(){});
但是 stream
既没有 destroy
也没有 end
或 stop
属性,我可以用它来停止进一步阅读的流
。
我确实提供了属性pause
Doc ,但我宁愿阻止 Node 读取整个文件,也不愿停止接收内容(如文档中所述)。
最佳答案
我最终使用了以下脏解决方法:
var aborted = false;
stream.on('data', function(chunk){
if(aborted) return res.end();
// stream contents
});
req.connection.on('close',function(){
aborted = true;
res.end();
});
如上所述,这并不是一个很好的解决方案,但它确实有效。
任何其他解决方案将不胜感激!
关于node.js - 在客户端连接关闭时中止 ReadStream,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/17903393/
如何获取可写流并从缓冲区返回可读流? 我有以下方法将来自 ftp 服务器的数据写入 block 数组: let chunks = [] let writable = new Writable writ
所以我有这个代码: downloadFile(file_id) { return new Promise((resolve, reject) => { var mongoose
我正在使用以下代码逐行读取一个大文件(大于内存): var fs = require('fs'); var readline = require('readline'); var stream = r
我正在使用 node.js 为 Linux 编写键盘事件解析器。它工作得还不错,但有时 Node 似乎跳过了几个字节。我正在使用 ReadStream获取数据,处理它,处理它,并最终在遇到分隔符时输出
所以我有这个代码: downloadFile(file_id) { return new Promise((resolve, reject) => { var mongoose
我偶尔想通过电子邮件通知发送大型日志文件 (>100MB) 的最后 2kB。现在,我正在尝试以下操作: var endLogBytes = fs.statSync(logFilePath).size;
我正在尝试发送一个(巨大)文件,每秒传递的数据量有限(使用 TooTallNate/node-throttle ): var fs = require('fs'); var Throttle = re
Firebase 存储的读取流: 我的 Google firebase 存储中有一些文件,我想为其创建读取流(使用 javascript/node js)。 (然后我打算将此读取流传输到一些中间件,然
我想将流作为参数传递给函数并在异步回调中使用它,但它已被销毁(stream.readable 为 false) 例如: var test = require('./test'); var file =
我现在正在编写一个生成文件的程序。我想知道关于 Stream(s) 的最佳实践是什么,尤其是在大小方面?我可以想象,如果一个流变得太大,它会带来一些减速或其他性能问题。 我有以下代码,可以调用很多次,
我觉得我对缓冲区和文件流缺乏了解,但我无法从其他答案中找到任何将base64字符串视为实际文件的具体想法。 我使用了 Npm 中的“request”包,通过 http、多部分协议(protocol)将
当我尝试发送读取流作为响应时,我收到错误 var http = require('http'), fileSystem = require('fs'), pat
我正在尝试在前端语言中使用 Swift,在后端语言中使用 Python 来实现基于套接字的聊天应用程序。我按照教程 http://www.raywenderlich.com/3932/networki
当客户端应用程序尝试发送带有 base64 编码图像的 POST 请求时,服务器抛出此错误。 Error at readStream (/Users/.../node_modules/raw-
我搜索了如何使用“assets”目录下的资源,然后我找到了一个 fragment : AssetManager assets = getAssets(); ((TextView)findViewByI
我正在使用 nodejs 和 express4。我有一个表单 - 发布方法(文件上传为 base64),我将这个文件保存到带有流的 gridfs 中。 这是我的代码: exports.transcri
我是delphi新手,这是我的第一个项目。这是一些代码: procedure TForm1.Button2Click(Sender: TObject); responseStringFromServe
请帮助修复错误: 20/04/09 18:38:44 ERROR MicroBatchExecution: Query [id = 9f3cbbf6-85a8-4aed-89c6-f5d3ff9c40
大家好!我遇到问题:我正在尝试验证注册表单。总的来说,它工作正常,但我需要通过服务器验证表单。例如,就我而言,我需要确定电子邮件是否已被占用。 我尝试获取和异步/等待语法,但问题仍然相同:DOMExc
我目前正在开发一个项目,该项目要求在将内容发送回浏览器之前对其进行 gZip 压缩。 我目前使用简单的读取流并将数据传输到请求的响应,但我不确定在不阻塞请求的情况下 gZip 内容的最佳方法 发送数据
我是一名优秀的程序员,十分优秀!