rxcpp

1热度

2回答

我正在学习C++的反应，我正在寻找一些指导。我创建了一个函数来等待一个事件然后返回它。我想捕获所有发生的反应性异步事件，并在他们来临时处理它们。这是我到目前为止有： int Engine::Initialize() { al_init(); display = al_create_display(1200, 800); eventQueue = al_creat

1热度

1回答

RxCPP行为不同于Rx.Net

我正在使用RxCPP，并且难以理解其行为。这里有两个程序，一个在Rx.Net中，另一个在RxCPP中。他们假设输出相同的照片，但他们不。该程序从鼠标流中获取点数，并计算点之间的三角洲流。鼠标是一串流的点，每一笔 - 从下往上按是一个流。老鼠一个接一个地给这些流。在这些试验中的期望的输出是：德尔塔无0：0,0 德尔塔无1：5,0 德尔塔无2是：0,5 德尔塔无3是：2,3 这是Rx.Ne

2热度

1回答

创建一个Observable，您可以在RxCpp中取消订阅

我正在从C＃移植一些严重依赖Rx的代码，并且我很难找到一些最常用的C＃方法的C++等价物。特别是，我想从订阅/取消订阅逻辑创建一个observable。在C＃中，我使用Observable.Create<TSource> Method (Func<IObserver<TSource>, Action>)重写来创建一个observable。例如 var observable = Observabl

2热度

1回答

如何rxcpp

处理请求/响应流，我需要在rxcpp实现相机采样系统..我想象这是传递一个requestStream为PARAM和接收responseStream 每次requestSample的调用方式，创建一个新的相机会话，当on_complete（）被调用的requestStream，相机会话终止 observable<ImageSample> requestSampleStream(observable<

2热度

1回答

RXCPP：阻塞函数超时

考虑一个阻塞函数：this_thread :: sleep_for（milliseconds（3000））; 我试图获得以下行为： Trigger Blocking Function |---------------------------------------------X 我想要触发闭锁功能，如果时间过长（超过两秒钟），它应该超时。我已经做了以下内容： my_connecti

3热度

1回答

rxcpp - 为什么所有观察者的on_next函数在observable发出值时都会被调用

我想了解如何使用rxcpp，我的印象是当observable发出一个值时，所有订阅的观察者都会通过调用他们的on_next（）方法来获得通知，将它们的发射值传递给它们。这是不是与下面的示例中的情况：我所期望的输出是这样的 auto eventloop = rxcpp::observe_on_event_loop(); printf("Start task\n"); auto values

3热度

1回答

rxcpp：嵌套的while循环或类似的“经典”命令结构的程序

我有一个设备可以传输一些事件。我想使用反应式扩展来建模以下行为：检测用户连接加密狗（我的程序检查连接加密狗的事件）。开始从加密狗获取一个数据流，然后连接加密狗。能够检测加密狗何时断开连接并返回到1.稍后如果用户再次连接加密狗，我想要转到2.在键盘被击中的情况下流式传输数据的状态下，程序结束。我知道如何等待加密狗连接（1）： auto waitForDongle = events.take_

2热度

1回答

rxcpp简单可观察<int>

我在C＃中使用RX进行编程，现在我想用C++中的rxcpp进行编程。我正在尝试做最简单的事情，定义一个类成员变量observable<int>。问题是，observable被定义为： template<class T, class SourceOperator> class observable 什么是SourceOperator？如何定义简单的observable<int>？当寻找

1热度

1回答

RXCPP：创建一个不关心可观察对象输入类型的扩展

我希望做一个不关心它所接收的可观察类型的扩展函数。例如： template <typename T> inline auto makeones() -> function<observable<int>(observable<T>)> { return [=](observable<T> s) { return s | rxo::map([=](auto x) { return

1热度

1回答

使用RxCpp构造观察者/可观察模式

我试图在Rx-cpp中实现observer/observable模式。这些是Rx.Net中的一个非常有趣的tutorial，有人可以这样做。在这个C#例子，有具体的interfaces，我们必须覆盖： public interface IObserver<in T> { void OnCompleted(); void OnError(Exception error);