問題タブ [node.js-stream]

data、error、およびイベントをリッスンして処理するストリームがありend、関数を呼び出しdataて最初のストリームの各イベントを処理します。当然、データを処理する関数は他のコールバックを呼び出し、非同期にします。では、ストリーム内のデータが処理されているときに、さらにコードの実行を開始するにはどうすればよいでしょうか? ストリームでイベントをリッスンしても、非同期処理関数が終了したendことにはなりません。data

次のステートメントを実行するときに、ストリーム データ処理関数が確実に終了するようにするにはどうすればよいですか?

次に例を示します。

callThisOnlyAfterAllAccountsAreMigratedストリームが処理された後に呼び出されるようにするにはどうすればよいですか?

これは約束で行うことができますか？スルーストリームで実行できますか? 私は Nodejs を使用しているので、他の npm モジュールを参照すると役立つ場合があります。

問題をよりよく説明するために更新されました:実装者がオリジンサーバーからの応答をリッスンして変更できるようにする単純なプロキシサーバーモジュールを構築しようとしています。プロキシが応答を受信するcustomResponseと、応答ストリームへの参照を含むメッセージを送信しています。そのイベントをリッスンする人は誰でも、応答にパイプして、カスタム ビジネス ロジックを実装できる必要があります。モジュールは、クライアントに戻る「最終」パイプを処理する必要があります。そうしないと、プロキシにはなりません (以下のコード例を参照)。

1. インストール

   /li>

2. index.js

   /li>

Busboyモジュールと少し混乱しています。リクエストヘッダーのみをパラメーターとして受け入れるため、ファイルデータをストリーミングする場所がわかりません?! ドキュメントの例を見てください：

非常に大きなファイルを処理するために、読み取り可能な変換ストリームを使用しようとしています。私が直面しているように見える問題は、最後に書き込み可能なストリームを配置しないと、結果が返される前にプログラムが終了するように見えることです。

例 ：rstream.pipe(split()).pipe(tstream)

私tstreamには、カウンターがしきい値に達したときに放出するエミッターがあります。そのしきい値が低い数値に設定されている場合は結果が得られますが、高い場合は何も返されません。ファイルライターにパイプすると、常に結果が返されます。明らかな何かが欠けていますか？

コード：

ここにコードがありますQtransformstream

これは Node.Js で行うべきことです

127.0.0.1:3000を開くはずの「node server.js」と書かれた6:16で立ち往生していますが、このエラーだけが表示されます。

私のブラウザでは、「ERR_CONNECTION_REFUSED」と表示されます

XAMMP には何の問題もなく、ベータ テストのためにポート 80 を開く必要はありません。