ReactiveX / RxCpp

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

RxCpp and Boost.Asio scheduler timeout #528

Open david-hoze opened 4 years ago

david-hoze commented 4 years ago

Hi, checkout https://github.com/david-hoze/RxCppAsioTimeout, another repo with a repro :smile:

The repo contains a few experiments with timeout. There are three experiments there, and these are the corresponding MACRO defines to turn each of them on:

DEFAULT: No scheduler specified, I'm getting a delay of 1 second (the timeout period) for each value! ASIO: Using Boost.Asio scheduler, behaves normally but gets stuck.. I believe the observable never completes for some reason.. NEW_THREAD: Using synchronize_new_thread, behaves normally.

Could you explain the first two experiments' weird behavior? Also, does the NEW_THREAD experiment means that a thread is created for each value?