From 00a2300cd3cab6db1f0c3d2a7c2b5a64dbb50819 Mon Sep 17 00:00:00 2001
From: sorairo <sorairo@shiosyakeyakini.info>
Date: Thu, 24 Oct 2024 20:45:03 +0900
Subject: [PATCH] =?UTF-8?q?=E8=A4=87=E6=95=B0=E3=81=AE=E6=8E=A5=E7=B6=9A?=
 =?UTF-8?q?=E3=81=8C=E3=81=82=E3=82=8B=E5=A0=B4=E5=90=88=E3=81=AB=E3=81=A1?=
 =?UTF-8?q?=E3=82=83=E3=82=93=E3=81=A8=E5=86=8D=E8=AA=AD=E8=BE=BC=E3=81=A7?=
 =?UTF-8?q?=E3=81=8D=E3=81=AA=E3=81=84=E4=B8=8D=E5=85=B7=E5=90=88=E3=82=92?=
 =?UTF-8?q?=E4=BF=AE=E6=AD=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 lib/src/services/streaming_service_impl.dart | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/lib/src/services/streaming_service_impl.dart b/lib/src/services/streaming_service_impl.dart
index dec10ea..f593c03 100644
--- a/lib/src/services/streaming_service_impl.dart
+++ b/lib/src/services/streaming_service_impl.dart
@@ -216,9 +216,9 @@ class StreamingService implements StreamingController, WebSocketController {
       _activeStreams--;
       if (_activeStreams == 0) {
         _subNotes.clear();
-        final lock = await _connectWebSocketMutex.acquire();
         if (_connections.isEmpty) {
           log("attempt $host streaming closed...");
+          final lock = await _connectWebSocketMutex.acquire();
           try {
             await _close();
           } finally {