Rxcpp:如何复制OfType运算符

Question

我有类：

class base_event;

从中派生出几个类：

class event_1 : base_event;
class event_2 : base_event; 

我有一个可观察的：

observable<base_event> o；

我想订阅o并分别获得event_1和event_2。

o.of_type(event_1).subscribe([](event_1& e){});
o.of_type(event_2).subscribe([](event_2& e){});

有没有办法创建这样的of_type运算符？

Answer 1

表示of_type的一种方法是使用

o.filter([](const shared_ptr<base_event>& be){ 
return dynamic_cast<event_1*>(be.get()) != nullptr;
})
.map([](const shared_ptr<base_event>& be){
return static_pointer_cast<event_1>(be);
})

另一个是使用

.map([](const shared_ptr<base_event>& be){
auto event = dynamic_pointer_cast<event_1>(be);
if (event == nullptr) { return empty<event_1>().as_dynamic();}
return just<event_1>(event).as_dynamic();
})
.concat()

我更喜欢第一个。