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

2019-08-23 23:08:45 阅读：192 来源： 互联网

我有一个设备可以传输一些事件.我想使用反应式扩展来模拟以下行为：

>检测用户何时连接加密狗(我的程序检查连接加密狗的事件).
>连接加密狗后,开始从加密狗捕获数据流.
>能够检测到加密狗何时断开连接并返回1.以后,如果用户再次连接加密狗,我想转到2.如果键盘被击中我流数据的状态,则程序结束.

我知道如何等待加密狗连接(1.)：

auto waitForDongle = events.take_while([](auto const & event) {
      return event == DongleConnected
      }).subscribe([](auto) {});

我知道如何捕获流(2.)：

auto streamMotionData = events.take_while([](auto const &) { return !keyboardPressed(); })
    .map([](auto const & evt) -> boost::optional<std::vector<double>> {
            ...
            return data;
        }).subscribe([](vector<double> const &) { ...});

我的问题是我不知道如何组合流以便回到1.以及之后2.我只知道如何一次又一次地执行此操作.但我想要上述行为.

解决方法:

这与Rx中的常见UX拖动示例有关.在这种情况下,印刷机是加密狗连接,释放是加密狗移除.

该解决方案要求一次只能连接一个加密狗(在下一次连接之前预期移除).事件中必须有更多信息才能允许多个连接重叠.

这是解决方案的核心.整个计划如下.

    auto DatasFromConnectedDongle = DongleConnects. // when connected
        map([=](DongleEvent const & event){
            assert(event == DongleEvent::Connected);
            cout << "Connected - " << flush;
            return DongleDatas. // return all the datas
                take_until(DongleRemoves). // stop when removed
                finally([](){
                    cout << "- Removed" << endl;
                });
        }).
        switch_on_next(). // only listen to datas from the most recent connected dongle
        take_until(Exits); // stop everything when key is pressed

我最终使用了repeat(),但只生成了测试事件数据.

#include <rxcpp/rx.hpp>

namespace Rx {
using namespace rxcpp;
using namespace rxcpp::sources;
using namespace rxcpp::operators;
using namespace rxcpp::util;
}
using namespace Rx;

#include <cassert>
using namespace std;
using namespace std::chrono;

int main()
{
    //
    // test code
    //

    auto keyboardPressed = [](){
        return false;
    };

    enum class DongleEvent {
        Connected,
        Removed,
        Data,
        Other
    };
    auto events = from(
            DongleEvent::Data, DongleEvent::Other, 
            DongleEvent::Connected, DongleEvent::Data, 
            DongleEvent::Other, DongleEvent::Other, 
            DongleEvent::Data, DongleEvent::Removed, 
            DongleEvent::Other, DongleEvent::Data).
        repeat(5). // send the above events five times over
        zip(take_at<0>(), interval(milliseconds(200))). // pace our test data
        publish().
        ref_count(); // publish and ref_count make the events sharable

    //
    // the solution
    //

    // fires when connected
    auto DongleConnects = events.
        filter([](DongleEvent const & event) {
            return event == DongleEvent::Connected;
        });

    // fires when data arrives
    auto DongleDatas = events.
        filter([](DongleEvent const & event) {
            return event == DongleEvent::Data;
        });

    // fires when removed    
    auto DongleRemoves = events.
        filter([](DongleEvent const & event) {
            return event == DongleEvent::Removed;
        });

    // fires when key pressed    
    auto Exits = interval(milliseconds(200)).
        filter([=](long){
            return keyboardPressed();
        });

    auto DatasFromConnectedDongle = DongleConnects.
        map([=](DongleEvent const & event){
            assert(event == DongleEvent::Connected);
            cout << "Connected - " << flush;
            return DongleDatas. // return all the datas
                take_until(DongleRemoves). // stop when removed
                finally([](){
                    cout << "- Removed" << endl;
                });
        }).
        switch_on_next(). // only listen to datas from the most recent connected dongle
        take_until(Exits); // stop everything when key is pressed

    DatasFromConnectedDongle.subscribe([](DongleEvent const & event){
        assert(event == DongleEvent::Data);
        cout << "Data " << flush;
    });

    return 0;
}

产生

~/source/rxcpp/Rx/v2/examples/dongle (master)$cmake .
...
~/source/rxcpp/Rx/v2/examples/dongle (master)$make
Scanning dependencies of target dongle
[ 50%] Building CXX object CMakeFiles/dongle.dir/main.cpp.o
[100%] Linking CXX executable dongle
[100%] Built target dongle
~/source/rxcpp/Rx/v2/examples/dongle (master)$./dongle 
Connected - Data Data - Removed
Connected - Data Data - Removed
Connected - Data Data - Removed
Connected - Data Data - Removed
Connected - Data Data - Removed
~/source/rxcpp/Rx/v2/examples/dongle (master)$

标签：c,reactive-programming,rxcpp
来源： https://codeday.me/bug/20190823/1701919.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

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