highland.js

0熱

2答えて

sourceStreamはBaseData個のオブジェクトで構成されています。このストリームをnにフォークしたいと思っています。さまざまなストリームの量をフィルタリングし、それぞれの好みのものに変換します。最後に、nストリームには特定のタイプのみが含まれています。フォークされたストリームの長さは、将来データが削除または追加される可能性があります。 { id: 'foo', data: 'poi

1熱

1答えて

大きなファイルとsplitbyメソッドを読み取る

splitbyメソッドをhighland.jsに使用して、開始区切り文字と終了区切り文字の間のデータを抽出しようとしています。 -----BEGIN DATA----- MIIEzDCCArSgAwIBAgIVCugKYzMN5ra8zPWxYE8pUU9SxjYSMA0GCSqGSIb3DQEB CwUAMHAxCzAJBgNVBAYTAkdCMRUwEwYDVQQID

0熱

1答えて

Highland.jsでフィルタを使用する（DBを使用する）

私はHighland.jsを使用してワークフローを設計しようとしています。私はHighland.jsがどのようにそれに使用できるのか把握できませんでした。 Iは、（擬似コード）は以下のようなストリームベースのワークフローを有する、 read //fs.createReadStream(...) .pipe(parse) //JSONStream.parse(...)

2熱

2答えて

大きなファイルからストリーミングしてアレイを作成する

highland.jsに問題があります。ストリームデータから関数の配列を作成する必要がありますが、それを動作させることはできません。ここで私のコードですが、requestsは常に空です。 var requests = []; _(fs.createReadStream("small.txt", { encoding: 'utf8' })) .splitBy('-----BEGIN

1熱

3答えて

ストリーム/ highland.jsを使用した結果からmongodbからデータを取得できません

私はストリームを初めて使用しており、reactive-superglue/highland.js（https://github.com/santillaner/reactive-superglue）を使用して自分のコレクションからデータを取得しようとしています。 var sg = require("reactive-superglue") var query = sg.mongodb("mong

0熱

1答えて

複数回ストリームを使用してクエリを実行することができません

現在、エンドポイントにカールしているときに応答を取得することはできますが、1回だけ行うことができます。私のサーバーへの追加要求は、stream error: Stream already being consumed, you must either fork() or observe()を引き起こします。私のスタック：node、express、highlandjs、mongodb。 //ser

0熱

1答えて

1つのストリームにエラーが発生した場合、flatMapに出力がないのはなぜですか？

私はhighland.jsのプログラムを書いて、いくつかのファイルをダウンロードし、解凍してオブジェクトに分解し、オブジェクトストリームをflatMapで1つのストリームにマージして出力しました。 function download(url) { return _(request(url)) .through(zlib.createGunzip()) .error

0熱

1答えて

ハイランドは一緒にメソッドを消費してtoArray

こんにちは人々と幸せな休日！高地でcsv行のストリームを消費しようとしています。特別な処理を行い、ヘッダーをストリームに渡さないようにするには、私は.consume()を呼び出しています。その結果を配列に入れたいと思っていました。問題は、.toArray()のコールバックが呼び出されないことです。私はすでに私の解決策を.map().toArray()に変更したのでこれについて興味がありますが、私

0熱

1答えて

HTTP node.jsでJSON配列をレンダリング

mongo dbを照会する明示的なGETリクエストからJSON文字列を取得しました。 res.write(string)が私に与える： [ { "_id":{ "epc":"30742503C40AE4AE128918B1", "audit":109 }, "ss":{ "x":1674, "y":96, "ts":

0熱

1答えて

高地のストリームを読み込み可能なストリームに変換するには？

私はhighlandストリームストリーミングストリングを持っています。今私は外部ライブラリ（私の場合はAmazon S3）でそれを消費したい、それはSDKのために私は標準ノードReadableストリームが必要です。ハイランドストリームをReadStreamに変換する方法はありますか？それとも私はそれを自分で変えなければならないのですか？