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);