Join broadcast queue when stopping raiden_service

raiden-network · Jan 7, 2021 · 0ca816c · 0ca816c
1 parent 6a56c19
commit 0ca816c
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/raiden/network/transport/matrix/transport.py b/raiden/network/transport/matrix/transport.py
@@ -567,6 +567,8 @@ def stop(self) -> None:
         if self._stop_event.ready():
             return
         self.log.debug("Matrix stopping")
+        # Ensure, we send all broadcast messages before shutting down
+        self._broadcast_queue.join()
         self._stop_event.set()
         self._broadcast_event.set()