node-streams

    2熱度

    1回答

    node.js中_writev()的正確用法是什麼? 文檔說: 如果流實現能夠處理一次數據的多個塊中,writable._writev()方法應來實現。 它還說: 的writable.cork()的主要目的是爲了避免在寫入數據的許多小塊,以流的情況下不會引起內部緩衝區備份,將有不良對性能的影響。在這種情況下,實現方法的實現可以以更優化的方式執行緩衝寫入。 從流實現的角度來看,這沒關係。但是,從寫流

    0熱度

    1回答

    我試圖寫一個測試用例時錯誤地發出這個代碼的結果: s3.getObject({ Bucket: mediaBucket, Key: mediaId, }).createReadStream() 我有一個虛擬S3對象的測試,和我使用的MemoryStream到涵蓋呼叫成功的情況。我如何發出錯誤,所以我可以編寫一個測試,讓我測試.on('error') functio

    0熱度

    1回答

    我想從一個簡單的文本文件中讀取流,並在讀取流完成後記錄所有字符,但奇怪的是每次第一個字符總是未定義。 我不確定在從文本文件中讀取流時是否缺少任何東西。 ` const fs= require('fs'); const readStreams = fs.createReadStream('text.txt'); let data; readStreams.on('data',(dataChun

    0熱度

    1回答

    我正在嘗試使用Gulp製作靜態網站。我遇到了一個有趣的翻譯我在前一個版本中編寫的概念以及如何使用Gulp實現它的問題。 其中一個概念,如果我有文件,動態地包含其他文件。 --- title: Table of Contents include: key: book value: book-1 --- Introduction. 然後,其他文件包括那個鍵。 ---

    0熱度

    1回答

    我正在創建一個可讀流(來自包含JSON文檔的文件)的數組,並且試圖將它們傳遞給另一個流。 在文件中的數據通過...但我收到的管道輸送到流中的每個對象來了,我想知道從哪個文件中這一數據來源於: var fs = require('fs'); var path = require('path'); var JSONStream = require('JSONStream'); var tmp1

    0熱度

    1回答

    var fs = require('fs'); var child = require('child_process'); var http=require('http') var input_file = fs.createReadStream('./remo.mp3'); http.createServer(function (req,res) { var args = ['-ss'

    0熱度

    2回答

    我有兩個文件,每行都有一個UUID。每個文件都有幾十萬行(它們是從數據庫轉儲生成的)。這些文件需要排序並找到差異(添加/刪除)。這是很容易使用一些* nix的工具來完成,只需要幾秒鐘: $ sort file-a.txt > file-a-sorted.txt $ sort file-b.txt > file-b-sorted.txt $ diff file-a-sorted.txt file

    0熱度

    2回答

    我需要讀取數千行的日誌文件並將每行寫入Mongo數據庫。我正在使用節點流讀取文件。我正在使用'split'npm軟件包將文件分成'行'。由於網絡的考慮,MongoDB的寫入將比讀取的日誌文件花費更多的時間。 我的核心代碼如下所示: var readableStream = fs.createReadStream(filename); readableStream .

    0熱度

    1回答

    我想寫一大口的文件,請執行下列操作: 奔跑看任務,重建的任何模板變化把手模板。 如果構建失敗,它會通過notify()方法通知BrowserSync,這樣我就可以在瀏覽器中看到出現錯誤的彈出窗口。 手錶不應停止。 如果構建正常,則調用browserSync.reload()。 於是我想出了代碼以下PICE: function SomeTask() { return gulp.src('*

    0熱度

    1回答

    在Express中,流式響應很容易實現,因爲res是一個流對象。 但是,在羽毛自定義服務方法中,我怎樣才能將某些東西流化爲響應?