問題タブ [rxcpp]
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.
c++ - Rxcpp: OfType 演算子を複製するにはどうすればよいですか?
授業がある：
class base_event;
そこからいくつかのクラスが派生します。
私はオブザーバブルを持っています:
observable<base_event> o;
o にサブスクライブして、event_1 と event_2 を別々に取得したいと考えています。
このような of_type 演算子を作成する方法はありますか?
rxcpp - RxCPP 継続的に変更されている STL コンテナーから作成されたオブザーバブルをサブスクライブする方法
RxCPP の初心者はまだ学習中です...
いくつかのスレッドによって継続的に変更されているアイテムのベクトルがあります。私は、このベクトルをオーバータイムでサブスクライブし、何かがプッシュされるたびに onNext を呼び出すことができるようにしたいと考えています。
私のメインでは、次のようなものがあります。
現在の出力はただ:であり、他にはOnCompleted何もありません。ベクトルvecがスレッドで更新されるたびt1に onNext が呼び出され、出力が次のようになることを期待していました。
これを行う正しい方法は何ですか？