Changed nextdetacher::do_unsubscribe memeber to an atomic type.

1 files changed, 2 insertions, 2 deletions

diff --git a/Rx/v2/src/rxcpp/rx-subscriber.hpp b/Rx/v2/src/rxcpp/rx-subscriber.hpp
index 30adcfd..9d443a1 100644
--- a/Rx/v2/src/rxcpp/rx-subscriber.hpp
+++ b/Rx/v2/src/rxcpp/rx-subscriber.hpp
@@ -52,7 +52,7 @@ class subscriber : public subscriber_base<T>
             trace_activity().on_next_enter(*that, u);
             try {
                 that->destination.on_next(std::move(u));
-                do_unsubscribe = false;
+                do_unsubscribe.store(false);
             } catch(...) {
                 auto ex = std::current_exception();
                 trace_activity().on_error_enter(*that, ex);
@@ -61,7 +61,7 @@ class subscriber : public subscriber_base<T>
             }
         }
         const this_type* that;
-        bool do_unsubscribe;
+        std::atomic<bool> do_unsubscribe;
     };
 
     struct errordetacher