作为@substack纠正我#node，新的流API在节点V10使这更容易：

const Readable = require('stream').Readable;
const s = new Readable();
s._read = () => {}; // redundant? see update below
s.push('your text here');
s.push(null);

...之后，您可以自由地将其通过管道传输或以其他方式将其传递给您的目标消费者。

它不像恢复单行那样干净，但它确实避免了额外的依赖。

（更新：到目前为止，在 v0.10.26 到 v9.2.1 中，如果您没有设置，push直接从 REPL 提示调用将因not implemented异常_read而崩溃。它不会在函数或脚本内崩溃。如果不一致使您紧张，包括noop.)

不要使用 Jo Liss 的简历答案。它在大多数情况下都可以工作，但在我的情况下，它让我失去了 4 或 5 个小时的错误查找时间。不需要第三方module来执行此操作。

新答案：

var Readable = require('stream').Readable

var s = new Readable()
s.push('beep')    // the string you want
s.push(null)      // indicates end-of-file basically - the end of the stream

这应该是一个完全兼容的可读流。有关如何正确使用流的更多信息，请参见此处。

旧答案：只需使用本机 PassThrough 流：

var stream = require("stream")
var a = new stream.PassThrough()
a.write("your string")
a.end()

a.pipe(process.stdout) // piping will work as normal
/*stream.on('data', function(x) {
   // using the 'data' event works too
   console.log('data '+x)
})*/
/*setTimeout(function() {
   // you can even pipe after the scheduler has had time to do other things
   a.pipe(process.stdout) 
},100)*/

a.on('end', function() {
    console.log('ended') // the end event will be called properly
})

请注意，不会发出 'close' 事件（流接口不需要）。

从节点 10.17 开始，stream.Readable 有一种from方法可以轻松地从任何可迭代对象（包括数组文字）创建流：

const { Readable } = require("stream")

const readable = Readable.from(["input string"])

readable.on("data", (chunk) => {
  console.log(chunk) // will be called once with `"input string"`
})

请注意，至少在 10.17 和 12.3 之间，字符串本身是可迭代的，因此Readable.from("input string")可以工作，但每个字符发出一个事件。Readable.from(["input string"])将为数组中的每一项（在本例中为一项）发出一个事件。

另请注意，在以后的节点中（可能是 12.3，因为文档说当时函数已更改），不再需要将字符串包装在数组中。

https://nodejs.org/api/stream.html#stream_stream_readable_from_iterable_options

只需创建streammodule的新实例并根据您的需要对其进行自定义：

var Stream = require('stream');
var stream = new Stream();

stream.pipe = function(dest) {
  dest.write('your string');
  return dest;
};

stream.pipe(process.stdout); // in this case the terminal, change to ya-csv

或者

var Stream = require('stream');
var stream = new Stream();

stream.on('data', function(data) {
  process.stdout.write(data); // change process.stdout to ya-csv
});

stream.emit('data', 'this is my string');

编辑： 加思的答案可能更好。

我的旧答案文本保留在下面。

将一个字符串转换成流，你可以使用一个暂停通过流：

through().pause().queue('your string').end()

例子：

var through = require('through')

// Create a paused stream and buffer some data into it:
var stream = through().pause().queue('your string').end()

// Pass stream around:
callback(null, stream)

// Now that a consumer has attached, remember to resume the stream:
stream.resume()