combine_latest thread safe

[finch-yihe]

when I try to run this code, it turns out that the member is_set of the class rxcpp::util::detail::maybe is false and std::terminal() was called, like this: anyone can help me?

[finch-yihe]

how can i promise thread safety about using combine_latest with two different observable in two different thread

[nikobarli]

Try to pass "coordination" to combine_latest, e.g.

o1.combine_latest(rxcpp::observe_on_new_thread(), o2)

For operators receiving it's input from two or more observables injected by multiple threads, you should put coordination to handle the synchronization.

[finch-yihe]

Try to pass "coordination" to combine_latest, e.g.

o1.combine_latest(rxcpp::observe_on_new_thread(), o2)

For operators receiving it's input from two or more observables injected by multiple threads, you should put coordination to handle the synchronization.

thank u