fix a data race in the async_observable constructor