Rxcpp:如何复制OfType运算符？

#include <rxcpp/rx.hpp>

using namespace rxcpp;

int main() {
    // 创建一个Observable对象
    auto observable = observable<>::create<int>(
        [](subscriber<int> s) {
            s.on_next(1);
            s.on_next(2);
            s.on_next(3);
            s.on_next(4);
            s.on_completed();
        }
    );

    // 使用Filter操作符筛选出指定类型的事件
    auto filteredObservable = observable
        .filter([](int value) { return value % 2 == 0; });

    // 订阅筛选后的Observable对象
    filteredObservable.subscribe(
        [](int value) { std::cout << value << std::endl; },
        []() { std::cout << "Completed" << std::endl; }
    );

    return 0;
}