問題タブ [mostjs]

循環依存関係を持つ多数のストリームがあります。

.thru(...)ストリームを受け取るために渡された関数は.filter()、.map()、などの演算子の組み合わせを適用します.until()が、特に (理由については以下を参照してください)、.delay().

これらは私がすでに試したことです：

方法 1

ここでの問題は、前もってサンプルにストリームを渡す必要がありますが、and のstreamC前に宣言できないことです。streamAstreamB

方法 2 (または 1.1)

このメソッドはメソッド 1 に基づいていますが、most-subjectを使用して事前に宣言できるイベントstreamC_proxyをプロキシするだけです。streamC

これは実際に機能すると思いますが、most-testを使用してテストすることはできません(独自のスケジューラを使用する必要がありますが.subscribe()、.observe()暗黙的に を使用しますdefaultScheduler)。私が言ったように.delay()、デフォルトのスケジューラーを使用してテストを実行するために秒/分を使用して待機することは現実的ではありません。

方法 3

このコードが理想からかけ離れていることを除けば、うまくいくはずです。しかし、そうではありません:(

質問

これはテスト可能な方法で行うことができますか?

既存のストリーム作成方法 ( https://github.com/cujojs/most/blob/master/docs/api.md )に準拠していないソースからストリームを作成するための現在のベスト プラクティスに興味があります。

Firebase の を使用した例ref.on('child_added', function(snap){}):

使えません.fromEvent… ref は何らかの を実装していますonが、EventEmitter インターフェイス (addEventListener、removeEventListener) に準拠していないようです。

手動でイベントを発行することは、現時点で私が考えることができる最高のものです...

Rx のようにカスタム ストリームを作成する同様のメカニズムはありますか?

私が見逃しているより良い方法はありますか？

オートバイを使用して小さなアプリケーションを作成しています。すべての requestAnimationFrame で関数を呼び出す必要があります。これは副作用なので、「効果的な」コンポーネントで実行する必要があることはわかっています。ただし、ほとんどの js は、 requestAnimationFrame ストリームを作成するためのperiodic()やなどのソースを提供していません。now()このような機能をアプリケーションに実装するにはどうすればよいですか?