問題タブ [highland.js]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
node.js - Highland.js の CombineLatest
CombineLatestと Highlandのような動作を実現するにはどうすればよいですか? 図書館には似たようなものはないようです
javascript - Highland.js ストリームを公開するが、終了イベントを内部で処理する
Node.js を使用して PostgreSQL データベースからデータを読み取っています。
オブジェクトは、行が受信されるたびにイベントqueryを発行するイベント エミッターになりました。rowさらに、endすべての行が読み取られるとイベントを発行します。
ここでやりたいことは、このイベント エミッターを Highland.js ストリームにラップし、これを関数の呼び出し元に渡すことです。基本的に、これは仕事をするはずです:
残念ながら、disconnectすべての行が読み取られたら関数を呼び出す必要があり、呼び出し元にこれを気にさせたくありません。endでは、イベントのコールバックを登録しながらストリームを渡すにはどうすればよいでしょうか?
Highland.js は、必要なことを正確に実行するdone関数を提供することを見てきましたが、ストリームが流れ始めます (これは内部で実行したくありません。それは呼び出し元次第です)。
どうすればこれを解決できますか?
node.js - Compose を使用して関数チェーンを表現するにはどうすればよいですか?
highlandjsライブラリを使用してファイルを読み取り、その内容にエンド カードを追加してから、コンソールに表示しています。
highland.composeこれらを単一の関数呼び出しにラップするために使用したいと思います。
エラーが発生します：
構成された関数が を返していないようhighland streamです。
javascript - highland.js を使用して、ストリームを消費する前に何かを行う
オブジェクトのストリームを取り、それらをmongodbデータベースに入力する書き込み可能なストリームをコーディングしようとしています。オブジェクトのストリームを消費する前に、最初にデータベース接続が確立されるのを待つ必要がありますが、プログラムが挿入部分に到達しないため、何か間違っているようです。
プログラムは「接続が確立されました！」なしで終了します。コンソールに書き込まれます。
私は何が欠けていますか？私が従うべきイディオムはありますか？
javascript - HIghland.js: fork() と observe() の違いは何ですか?
observe()他の消費者がすでに働いていない限り、値を消費したり消費をトリガーしたりしないことを理解していfork()ますが、それ自体で消費をトリガーします。ただし、ストリームがあるとしますsource_stream。私が行った場合
次に、2 つのオブザーバーが同じ値を受け取ることが保証されます。でももしそうなら
2 つのフォーカーにはどのような値が入りますか? それらは同じでしょうか、違うでしょうか、それとも別のものでしょうか? それらにプッシュされる値を決定するルールは何ですか? ありがとう！
javascript - highland.js は json 配列を取得し、値のストリームに変換します
外部 API から JSON 配列をフェッチし、一度に配列の 1 つの要素を出力しようとしています。ただし、実装がどこかで失敗しているようです。配列ではなくエラーが発生しています