問題タブ [through2]

私はこれを読んで、例に基づいてコードを書きました。

私のコード:

const through = require('through2'); const bluebird = require('bluebird');

上記のプログラムを使用して、約 400 レコードの読み取りと削除を試みました。しかし、ログから、ストリーム promise ( streamToPromise(stream)) は解決されていますが、まだいくつかのレコードが残っていることがわかりました。ログから、私は得ました：

これを修正する方法は？ありがとう

Node.js 12 でカスタム トランスフォーマー ストリームを作成しようとしています。具体的には、ストリーム (データベース ドライバー) で json オブジェクトを取り込み、変換されたオブジェクトを返します。しかし、私のトランスフォーマー関数は決して呼び出されません。また、streams.Transform クラスをオーバーライドしてこれを試しました。

カスタム変換をジェネリックにしたいので、ジェネリック関数を渡すためにクロージャーで囲みます。

これを試すためのテスト リグは次のとおりです。

ストリームは機能しているように見え、実際の変換コードを呼び出すことはなく、常に元の json のみを返します。

コンソールで。

私は見ることを期待しています： { a: 1, b:2, c:2 }

EDIT：クラスを使用する別のバージョンもあり（through2をバイパス）、まったく同じ問題があります：