我有一个highland流流字符串。我想通过外部库(在我的情况下为Amazon S3)使用它,对于它的SDK,我需要一个标准的node Readable Stream

有没有一种方法可以将高地流转换为ReadStream?还是我必须自己改造它?

最佳答案

似乎没有内置的方法可以将高地流转换为Node Stream(根据当前的高地文档)。

但是高地流可以通过管道传递到Node.js流中。

因此,您可以使用标准的PassThrough流通过两行代码来实现这一点。

PassThrough流基本上是转发器。这是Transform流(可读和可写)的简单实现。



'use strict';

const h = require('highland');
const {PassThrough, Readable} = require('stream');

let stringHighlandStream = h(['a', 'b', 'c']);

let readable = new PassThrough({objectMode: true});
stringHighlandStream.pipe(readable);

console.log(stringHighlandStream instanceof Readable); //false
console.log(readable instanceof Readable); //true

readable.on('data', function (data) {
	console.log(data); // a, b, c or <Buffer 61> ... if you omit objectMode
});





它将根据对象模式标志发出字符串或缓冲区。

关于javascript - 如何将高地流转换为节点可读流?,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/41679008/

10-09 15:40