RxCpp
RxCpp copied to clipboard
Segmentation fault in case of using new_thread + current_thread
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"