- xml - AJAX/Jquery XML 解析
- 具有多重继承的 XML 模式
- .net - 枚举序列化 Json 与 XML
- XML 简单类型、简单内容、复杂类型、复杂内容
我有这样一个函数,它创建一个写入流,然后将字符串数组写入文件。我想让它在编写完成后返回一个 Promise。但我不知道如何才能完成这项工作。
function writeToFile(filePath: string, arr: string[]): Promise<boolean> {
const file = fs.createWriteStream(filePath);
arr.forEach(function(row) {
file.write(row + "\n");
});
file.end();
file.on("finish", ()=>{ /*do something to return a promise but I don't know how*/});
}
感谢您的任何评论!
最佳答案
您需要使用 Promise
constructor :
function writeToFile(filePath: string, arr: string[]): Promise<boolean> {
return new Promise((resolve, reject) => {
const file = fs.createWriteStream(filePath);
for (const row of arr) {
file.write(row + "\n");
}
file.end();
file.on("finish", () => { resolve(true); }); // not sure why you want to pass a boolean
file.on("error", reject); // don't forget this!
});
}
关于javascript - writestream 完成后如何返回 promise ?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/39880832/
我有一个 EventEmitter 对象,我设置它来监听事件。当事件发出时,我想将信息写入文件。我有一个打开的 FileStream 通过 fs.createWriteStream(path, { f
问题: 我有 fs.createWriteStream(filename),其中文件名是通过 res.pipe(); 写入的 mp3 文件。来自远程服务器的响应是永无止境的音频数据流。 Time-to
在我正在实现的 Vert.x verticle 中,我有一个之前加载到内存中的缓冲区,现在我想将它转储到磁盘中。 据我所知,我们应该使用 Pump 来确保不会使 WriteStream 过载。 但我没
考虑以下消息序列: 1. s := '' writeStream. 2. s nextPutAll: '123'. 3. s skip: -3. 4. s position "=> 0". 5. s
看看这个示例代码,它在 Nodejs 中创建文件的副本。 var fs = require('fs'); var out = fs.createWriteStream('1_GB_FILE_COPY'
如何在调用 WriteStream.write() 时将数据写入文件? 编辑:事实证明,当我使用 REPL 并调用该函数时,这是有效的。但是,这在我的程序中不起作用: import * as FS f
这是我想做的: stream = fs.WriteStream('crap.txt',{flags:'w'}; // more code response.on('close',function()
我已经创建了一个解析 NGinx 日志的模块,现在我正在编写一个使用它的命令工具。我的问题是我允许解析整个目录,这在读取然后解析方面不是问题,因为我有一个池可以读取和解析,但是,在命令行工具上,我允许
我有这样一个函数,它创建一个写入流,然后将字符串数组写入文件。我想让它在编写完成后返回一个 Promise。但我不知道如何才能完成这项工作。 function writeToFile(filePath
我用var writeStream = fs.createWriteStream('...')打开了一个WriteStream,但是没有writeStream.close()函数。这在 node 中是
两个Writestream在 Spark Structured Streaming 2.2.1 中,同一个数据库接收器不会按顺序发生。请建议如何使它们按顺序执行。 val deleteSink = d
考虑一个通用的 writeStream调用 - 使用典型的“控制台”输出格式: out.writeStream .outputMode("complete") .format("console
var http = require('http'); var fs = require('fs').createWriteStream('file1');; http.createServer(fu
我正在尝试在 Spark 中读取来自 kafka(版本 10)的消息并尝试打印它。 import spark.implicits._ val spark = SparkSe
我现在正在编写一个生成文件的程序。我想知道关于 Stream(s) 的最佳实践是什么,尤其是在大小方面?我可以想象,如果一个流变得太大,它会带来一些减速或其他性能问题。 我有以下代码,可以调用很多次,
也许我是在 JVM 的阴影下考虑这个问题,但是...... 我正在使用一个第三方 API,它有一个采用 WriteStream 的函数声明(我相信它只使用 .write() 方法)。 我希望能够直接使
我希望能够使用 node.js 和 pipe 方法监控副本的速度,以便我可以显示进度条、速度指示器以及最终的时间估算。 目前,在浏览一些引用资料时,我想我将不得不使用 writeStream.byte
const barStream = fs.createWriteStream('bar'); const foo = spawn('foo', [], { stdio: ['ignore', barS
我正在尝试使用 nodeJS 将经过处理的图像保存在 base64 字符串中。 var buff = new Buffer(base64data,'base64'); console.log(base
我正在 node.js 中编写一个纯同步的单线程命令行程序,它需要编写一个二进制文件,为此我使用 WriteStream。我的使用模式是这样的: var stream = fs.createWrite
我是一名优秀的程序员,十分优秀!