問題タブ [rx-py]

現在、呼び出し可能なオブジェクトを rxpy オブザーバブルにラップして、新しい値を処理する必要があることをオブザーバーに通知しようとしていますが、これを簡単に行う方法がわかりません。比較的経験豊富な C++/Qt 開発者です。

yieldキーワードを使用して、次のようなサンプルを機能させることができましたが、これはほとんどの状況ではあまり便利ではありません。

しかし、次の例を取ると:

!! 1私は出力としてのみ取得し2、 処理3さ4れることはなく、オブザーバーにそれらを処理させる方法が実際にはわかりませんが、さらに、MyObservableリストに値を追加するメソッドを実装する方法がわかりません。オブザーバーでの処理をトリガーします。

Observableから何か起動できるのではないかと思い、 の API を調べてみたのsourceですが、そうではないようです。

Qt と同じロジックを適用しようとしてrx/の哲学に明らかな何かが欠けているのでしょうか、それともそれを行う簡単な方法がありますか、それとも私の問題を解決するには、私のニーズに合った特殊化を実装する必要がありますか? ?rxpyObservable

とにかく、答えてくれてありがとう！

EDIT :私は完全に私を満足させない方法を見つけました.anとanのSubject両方であるクラスを使用して、そのメソッドを使用して、新しいデータがここにあることを外部サブスクライバーに通知できます:ObservableObserveron_next

このサンプルは、私が期待するものを示しています:

しかし、これは間違いなく私たちがこの種のことをすることを期待する方法ですか、それともオブジェクトrxpyをラップするよりもエレガントな方法はありますか?Subject