highland.js

4熱度

2回答

Async Map with Highland.js

我有一個定期從服務器獲取數據的高地流。我需要在地圖中進行數據庫查找。我找不到在高地的任何變壓器上做任何異步操作的情況。

0熱度

1回答

Highland.js如何實現背壓？

Highland.js究竟是如何實施反壓的？我對此很好奇。

0熱度

2回答

如何使用撰寫代表功能鏈？

我使用highlandjs圖書館閱讀文件，並在控制檯顯示它們之前添加結束卡，將其內容： const readFile = highland.wrapCallback(fs.readFile); const addEndCard = x => x + '\nx---THE END---x\n'; files.map(readFile).parallel(3).map(addEndCard).ea

0熱度

2回答

node.js中的依賴管理與highland.js

我從node.js中獲得了巨大的價值，並熱愛流處理模型。我主要將它用於數據豐富和ETL類作業的流處理。富集，我可能有這樣的記錄... { "ip":"123.45.789.01", "productId": 12345 } 我想或許是增加產品細節的描述和數據 { "ip":"123.45.789.01", "productId": 12345, "description" : "Coca-C

0熱度

1回答

管道節點流與高地js並行

我有一個異步節點流的數組，我想並行使用是否有一個簡單的方法來做到這一點在高地js？我試圖讓所有這些數組通過聚合函數。

1熱度

2回答

Highland.js中的流上的異步轉換

我試圖在一組Mongoose模型上使用Highland.js作爲數據庫更新腳本，它似乎非常適合在Model.find()上調用QueryStream。我有一些同步的事情要做（更新我的模型以符合新的模式，一些清理操作），最後我想要save()這個文檔。我配置了一些需要運行的預保存鉤子，並且這些更新與直接Model.update()不兼容。我已經成功地得到它通過Q.js和高地的組合工作排序的： var

0熱度

1回答

結合使用高地與節點客戶端

我正在嘗試使用highland與heroku-client結合使用。但在Heroku客戶端的內部，它使用this，即使我嘗試bind來綁定這個，函數給出了錯誤消息，並且有一個對於this的錯誤消息，我無法使其工作。沒有權代碼看起來像這樣 const Heroku = require('heroku-client'); const hl = require('highland'); var h

8熱度

2回答

highlandjs中的循環數據流

我剛剛在NoFlo.js的啓發下學習了highland.js。我希望能夠遞歸地操作流。在這個人爲的例子中，我將提供一個乘以2的數字，我們過濾結果< = 512。一旦數字相乘，它就會反饋到系統中。我有代碼的工作，但如果我拿出管道中的多託功能它不處理任何數字。我懷疑我不正確地將數據發送回returnPipe。有沒有更好的方法將數據傳回系統？我錯過了什麼？ ### input>--m--->m

3熱度

1回答

Highland.js CSV解析

我試圖寫一個非常實用的方式。我們使用Highland.js來管理流處理，但是因爲我太新了，我想我對如何處理這種獨特的情況感到困惑。這裏的問題是文件流中的所有數據都不一致。文件中的第一行通常是頭，我們希望將其存儲到內存中，然後壓縮流中的所有行。這是我第一次去吧： var _ = require('highland'); var fs = require('fs'); var stream

12熱度

2回答

Highland.js，Kefir.js和Rx.js之間的區別特徵是什麼？

因爲主觀答案要避免在SO上，所以我具體問：這三個功能/反應性庫之間的功能和/或性能差異是什麼，這會使我選擇其中一個作爲其他功能/反應性庫？我已經淘汰了BaconJS，因爲它依賴於jQuery。我不熟悉JS流，主要感興趣的是先開始在NodeJS中熟悉它們，然後再在AngularJS上下文中熟悉它們。如果你選擇了其中的一個，那麼什麼標準導致選擇？