From d2a6ed9100df66949905d551162e96c826fc4332 Mon Sep 17 00:00:00 2001
From: PobreGato <315121269+pobregat0@users.noreply.github.com>
Date: Mon, 17 Aug 2026 03:45:16 +0300
Subject: [PATCH] use lock_guard for streams mutex

---
 libi2pd/Streaming.cpp | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/libi2pd/Streaming.cpp b/libi2pd/Streaming.cpp
index 497f4848..95c3c078 100644
--- a/libi2pd/Streaming.cpp
+++ b/libi2pd/Streaming.cpp
@@ -2162,7 +2162,7 @@ namespace stream
 		m_PendingIncomingTimer.cancel ();
 		m_PendingIncomingStreams.clear ();
 		{
-			std::unique_lock<std::mutex> l(m_StreamsMutex);
+			std::lock_guard<std::mutex> l(m_StreamsMutex);
 			for (auto it: m_Streams)
 				it.second->Terminate (false); // we delete here
 			m_Streams.clear ();
@@ -2326,7 +2326,7 @@ namespace stream
 	std::shared_ptr<Stream> StreamingDestination::CreateNewOutgoingStream (std::shared_ptr<const i2p::data::LeaseSet> remote, int port)
 	{
 		auto s = std::make_shared<Stream> (m_Owner->GetService (), *this, remote, port);
-		std::unique_lock<std::mutex> l(m_StreamsMutex);
+		std::lock_guard<std::mutex> l(m_StreamsMutex);
 		m_Streams.emplace (s->GetRecvStreamID (), s);
 		return s;
 	}
@@ -2340,7 +2340,7 @@ namespace stream
 	std::shared_ptr<Stream> StreamingDestination::CreateNewIncomingStream (uint32_t receiveStreamID)
 	{
 		auto s = std::make_shared<Stream> (m_Owner->GetService (), *this);
-		std::unique_lock<std::mutex> l(m_StreamsMutex);
+		std::lock_guard<std::mutex> l(m_StreamsMutex);
 		m_Streams.emplace (s->GetRecvStreamID (), s);
 		m_IncomingStreams.emplace (receiveStreamID, s);
 		return s;
@@ -2350,7 +2350,7 @@ namespace stream
 	{
 		if (stream)
 		{
-			std::unique_lock<std::mutex> l(m_StreamsMutex);
+			std::lock_guard<std::mutex> l(m_StreamsMutex);
 			m_Streams.erase (stream->GetRecvStreamID ());
 			if (stream->IsIncoming ())
 				m_IncomingStreams.erase (stream->GetSendStreamID ());