Undo recent damage to when a Channel is closed :(.

OrchidTechnologies · Jul 19, 2024 · 2f91fb5 · 2f91fb5
1 parent c28c69a
commit 2f91fb5
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/lib-protocol/source/channel.cpp b/lib-protocol/source/channel.cpp
@@ -131,19 +131,20 @@ task<void> Channel::Open() noexcept {
 task<void> Channel::Shut() noexcept {
     co_await Post([&]() {
         channel_->Close();
-        channel_->UnregisterObserver();
-
         const auto state(channel_->state());
         if (Verbose)
             Log() << "closed channel in state " << webrtc::DataChannelInterface::DataStateString(state) << std::endl;
         if (state != webrtc::DataChannelInterface::kClosed)
             Stop();
+    });
+
+    co_await Pump::Shut();
 
+    co_await Post([&]() {
+        channel_->UnregisterObserver();
         channel_ = nullptr;
         peer_ = nullptr;
     });
-
-    co_await Pump::Shut();
 }
 
 template <typename Type_, Type_ Pointer_>