问题标签 [rxcpp]

在探索 RxCpp 库时，我遇到了以下我无法解释的示例。

库中有两个observable类声明：

我无法理解的是编译器如何设法接受rxcpp::observable<>.片段。observable除了void,void. _

问题是编译器如何解释这段代码中的空尖括号：rxcpp::observable<>.

我在observable类中没有看到默认模板参数，也没有可以解释这一点的可变参数模板参数。

然后我认为它与显式模板专业化有某种关系，并试图在一个孤立的程序中重现它，例如像这样

然而，即使只有一个明确的特化，它也不会编译。

我有课：

class base_event;

几个类派生自它：

我有一个可观察的：

observable<base_event> o;

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

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

我试图在我的程序中包含 RxCpp，我注意到，框架调用了很多发射对象的复制构造函数。

运行此输出

我首先注意到这一点subject，我想发布一个在网络操作完成后在堆栈上创建的对象。在这种情况下，复制构造函数被调用（仅？） 4 次，但中间没有操作符，主题只有一个订阅者。

我知道，调用复制构造函数是必要的，因为多个观察者可能正在监听并且他们不能共享移动的对象。我还希望 observable 上的每个运算符都像另一个订阅者一样。

但是，我不明白为什么它在内部发生了这么多，尤其是在这个例子中。这感觉就像我做错了什么。有什么办法可以优化吗？如果只有一个订阅者，是否有充分的理由不使用移动构造函数？

std::shared_ptr通过可观察对象发出更大的对象以避免复制构造函数调用通常是一个好主意吗？

假设我有一个实体“地址”和一个实体“用户”，它们以 1-n 关系链接。客户端发送在我的控制器功能中评估的所有必要数据。

Controller 类在头文件中声明了两个必需的 Mapper：

(auth.h)

在控制器函数中，我想对两个实体使用映射器的插入方法，将数据异步插入表中。对于没有嵌套回调的地址和用户，等待两个插入的正确 C++ 方法是什么？欢迎使用 RxCpp 等库。

(auth.cc)

回调的类型为 std::function，但也有一个 std::future 类型的函数“insertFuture”可用

我正在尝试做一个每秒向api发出请求并获得答案并将其返回给我并将其添加到缓冲区的东西

对于查询我使用 cpr，对于其他所有我使用 rxcpp

我不知道怎么写，但这是我的尝试（希望你能帮助我）

虽然rxcpp::composite_subscription有一个方法unsubscribe，但它不会在销毁时调用它。

rxcpp 库是否包含一个unsubscribe在对象超出范围时自动调用的类？

RxCPP 上的新手仍在学习...

我有一个由某个线程不断修改的项目向量。我希望能够订阅此向量超时并在推送某些内容时调用 onNext。

在我的主要我有这样的事情：

当前输出只是：OnCompleted没有别的。我希望每当向量vec在线程中更新时t1， onNext 被调用，然后输出看起来像这样：

这样做的正确方法是什么？

我正在寻找有关使用RxCpp库处理事件流的本机延迟的信息，即处理一条简单消息（例如，指向对象的指针）的库开销是多少？从某个来源发布的事件到由一个琐碎（什么都不做）的观察者完成处理需要多少时间？

我做了很多网络搜索，但似乎无法找到任何基准。我不需要确切的数字，只要规模就足够了：是毫秒、微秒还是数百纳秒？