- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时,我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
如何在调用 WriteStream.write()
时将数据写入文件?
编辑:事实证明,当我使用 REPL 并调用该函数时,这是有效的。但是,这在我的程序中不起作用:
import * as FS from "fs";
import { LetterGroup } from "./LetterGroup";
import { Dictionary } from "./Dictionary";
import { Word } from "./Word";
import * as OS from "os";
const groups: Array<LetterGroup> = LetterGroup.letterGroupsFromString(FS.readFileSync("./letterGroups.txt").toString());
const dictionary = Dictionary.create(FS.readFileSync("./dictionary.txt").toString());
const inputStr: string = FS.readFileSync("./input.txt").toString();
const inputWords = new Array<Word>();
const fileStream = FS.createWriteStream("./output.txt");
for (const line of inputStr.trim().split(OS.EOL))
{
inputWords.push(new Word(line));
}
function permute(index: number)
{
index = Math.floor(index);
if (!(index >= 0 && index < inputWords.length))
{
return;
}
const word: Word = inputWords[index];
let outputString: string = "";
outputString += `Valid permutations of '${word.wordString}':` + OS.EOL;
console.log(`Testing '${ word.wordString }'...`);
for (const permutation of word.generatePermutations(groups, dictionary, true))
{
outputString += permutation.wordString + OS.EOL;
}
outputString += OS.EOL;
console.log();
if (!fileStream.write(outputString))
{
console.log("Wrote to file too fast! Will resume writing once the system catches up...");
fileStream.once("drain", () => permute(index));
return;
}
permute(index + 1);
}
permute(0);
应该注意的是,word.generatePermutations
是一个极其密集的函数,通常可能需要几分钟(有时超过一个小时)才能返回。我的问题是,它返回的数据应该立即写入输出文件,这样整个程序就不需要完成运行才能读取结果。希望有人能够理解这一切。
澄清一下,写入 REPL 中的 WriteStream
的数据会立即写入文件,而在我的程序中,直到整个程序运行完毕才将数据写入文件。
最佳答案
尝试这些包:
https://www.npmjs.com/package/flushwritable
https://www.npmjs.com/package/flush-write-stream
我认为你的问题是重复的 How to flush Node.js file writeStream properly?
关于Node.js WriteStream 在关闭之前不会将数据写入文件,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/48410361/
我有一个 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
我是一名优秀的程序员,十分优秀!