ReactiveX / RxCpp

Reactive Extensions for C++
Apache License 2.0
3.03k stars 390 forks source link

Segmentation fault in case of using new_thread + current_thread #595

Open victimsnino opened 1 year ago

victimsnino commented 1 year ago

Example:

    rxcpp::observable<>::range(1, rxcpp::observe_on_new_thread())
        .delay(std::chrono::seconds(1), rxcpp::identity_current_thread())
        .as_blocking()
        .subscribe([](const auto &v)
                   { std::cout << v << std::endl; },
                   []()
                   { std::cout << "COMPLETED"; });

Crashed near scheduling first emission inside "delay"