highland.js

0熱度

1回答

我正在嘗試使用Highland.js設計工作流程。我無法弄清楚Highland.js如何使用它。我有一個基於流的工作流程如下（僞代碼）， read //fs.createReadStream(...) .pipe(parse) //JSONStream.parse(...) .pipe(filterDuplicate) //mongoClient.db.coll

2熱度

2回答

從大文件流式創建陣列

我遇到了highland.js問題。我需要從我的流數據創建一個函數數組，但無法讓它工作。這是我的代碼，但requests始終爲空。 var requests = []; _(fs.createReadStream("small.txt", { encoding: 'utf8' })) .splitBy('-----BEGIN-----\n') .splitBy('\n

0熱度

1回答

highland.js異步數組到數據流

我想要得到以下代碼片段來返回相同的輸出 - 數組值的流。第一種方法從數組開始併發出值。第二種方法獲取解析數組的promise，所以不是發射每個值，而只是發出數組本身。我應該改變第二種方法，使其輸出與第一種相同的東西？ const h = require('highland'); var getAsync = function() { return new Promise((re

1熱度

1回答

讀取大文件和splitby方法

我試圖使用中的splitby方法來提取開始和結束分隔符之間的數據。 -----BEGIN DATA----- MIIEzDCCArSgAwIBAgIVCugKYzMN5ra8zPWxYE8pUU9SxjYSMA0GCSqGSIb3DQEB CwUAMHAxCzAJBgNVBAYTAkdCMRUwEwYDVQQIDAxXYXJ3aWNrc2hpcmUxEDAOBgNV

1熱度

1回答

Higland.js：包裝toCallback到承諾

我想寫類似： const Promise = require('bluebird') const H = require('highland') Promise.fromCallback( H([1, 2, 3]).toCallback ).then(function(val) { expect(val).eql(1, 2, 3) }) 但我看到了一個錯誤： Typ

0熱度

2回答

如何使用highland.js分叉流？

我有一個sourceStream組成的BaseData對象。我想分流這個流到n-不同的流的數量，然後過濾和轉換每個BaseData對象到他們的喜好。最後，我想要n只包含特定類型的流，並且分叉的流的長度可能會有所不同，因爲可能會在未來刪除或添加數據。我想我可以通過fork設置它這樣的： import * as _ from 'highland'; interface BaseData {

1熱度

1回答

使用異步處理高地流數據塊

我使用highland.js來處理使用流讀取兩個分隔符之間的內容的文件。我還使用async.js按順序運行一系列http請求。理想情況下，我想將來自高地的輸出x作爲第一個函數傳遞給async系列（鏈），以便爲從流中提取的每個塊執行HTTP請求。這可能嗎？如果是這樣，這怎麼能實現呢？ var async = require('async'); var _ = require('highland

0熱度

1回答

如何將高地流轉換爲可讀流？

我有一個highland流串流字符串。現在我想通過一個外部庫（在我的情況下是Amazon S3）來使用它，爲了這個SDK，我需要一個標準節點可讀流。有沒有辦法將高地流轉換爲開箱即用的ReadStream？還是我必須自己改造它？

0熱度

1回答

如何爲highlandjs輸入流的Streams流？

我正在使用typescript @ 2和highlandjs庫。高地的類型錯過mergeWithLimit(n)函數。它：注意到流的數據流，併合並他們的價值觀和錯誤成一個新的數據流，limitting取消暫停流，可以在任一個時刻運行的數量。現在，這種方法還沒有爲其DefinitlyTyped typings提供類型。我試圖添加它，但只有一個interface Stream<R>，沒有一個流

0熱度

2回答

如何使用異步函數消耗高地流？

使用異步函數消耗高地流的正確模式是什麼？看起來.each方法不適用於使用wrapCallback包裝的節點式異步函數。我想做類似以下的事情。請注意，我希望捕獲.each函數中生成的錯誤，並在所有異步消耗完成時觸發.done函數。 function asyncConsume(item,cb) { // perform async operation based on data strea