From dac02c2aaa5c9a052f467ff0349863eec0c0e66b Mon Sep 17 00:00:00 2001
From: Kuzin Roman <kuzin57@ydb.tech>
Date: Fri, 17 Jul 2026 11:27:32 +0300
Subject: LOGBROKER-10550 Fix verify on shutdown in sdk (#46840)

Co-authored-by: Roman Kuzin <kuzin57@yandex-team.ru>
---
 ydb/public/sdk/cpp/src/client/topic/impl/read_session_impl.ipp | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/ydb/public/sdk/cpp/src/client/topic/impl/read_session_impl.ipp b/ydb/public/sdk/cpp/src/client/topic/impl/read_session_impl.ipp
index ad21efc233f..b2d002573f4 100644
--- a/ydb/public/sdk/cpp/src/client/topic/impl/read_session_impl.ipp
+++ b/ydb/public/sdk/cpp/src/client/topic/impl/read_session_impl.ipp
@@ -1273,7 +1273,7 @@ inline void TSingleClusterReadSessionImpl<true>::OnReadDoneImpl(
     } else {
         pushRes = EventsQueue->PushEvent(
             partitionStream,
-            NPersQueue::TReadSessionEvent::TDestroyPartitionStreamEvent(std::move(partitionStream), msg.commit_offset()),
+            NPersQueue::TReadSessionEvent::TDestroyPartitionStreamEvent(partitionStream, msg.commit_offset()),
             deferred);
     }
 
@@ -1476,7 +1476,7 @@ inline void TSingleClusterReadSessionImpl<false>::StopPartitionSessionImpl(
         pushRes = EventsQueue->PushEvent(
             partitionStream,
             // TODO(qyryq) Is it safe to use GetMaxCommittedOffset here instead of StopPartitionSessionRequest.commmitted_offset?
-            TReadSessionEvent::TStopPartitionSessionEvent(std::move(partitionStream), committedOffset),
+            TReadSessionEvent::TStopPartitionSessionEvent(partitionStream, committedOffset),
             deferred);
     } else {
         // partitionStream->ConfirmDestroy();
@@ -1764,7 +1764,7 @@ inline void TSingleClusterReadSessionImpl<false>::OnReadDoneImpl(
 
     bool pushRes = EventsQueue->PushEvent(
             partitionStream,
-            TReadSessionEvent::TEndPartitionSessionEvent(std::move(partitionStream), std::move(adjacentPartitionIds), std::move(childPartitionIds)),
+            TReadSessionEvent::TEndPartitionSessionEvent(partitionStream, std::move(adjacentPartitionIds), std::move(childPartitionIds)),
             deferred);
     if (!pushRes) {
         AbortImpl(&deferred);
@@ -1879,7 +1879,7 @@ void TSingleClusterReadSessionImpl<UseMigrationProtocol>::DestroyAllPartitionStr
 
     for (auto&& [key, partitionStream] : PartitionStreams) {
         bool pushRes = EventsQueue->PushEvent(partitionStream,
-                                TClosedEvent(std::move(partitionStream), TClosedEvent::EReason::ConnectionLost),
+                                TClosedEvent(partitionStream, TClosedEvent::EReason::ConnectionLost),
                                deferred);
         if (!pushRes) {
             AbortImpl(&deferred);
-- 
cgit v1.3