subjects::synchronize lock with current_thread or immediate scheduler #491
Description
rxcpp::composite_subscription lifetime;
rxcpp::subjects::synchronize<int, rxcpp::identity_one_worker> sub(
rxcpp::identity_current_thread(), lifetime);
sub.get_subscriber().on_next(1);
lifetime.unsubscribe();This code locks in drain_queue
because the lock in
on_next is not unlocked
Should it be safe to call unlock before these lines?
RxCpp/Rx/v2/src/rxcpp/subjects/rx-synchronize.hpp
Lines 91 to 92 in 7c79c18
schedule should be thread-safe by contract if I am not mistaken.