Moved "ydb_persqueue_public: cancel previous client context on reconnect" commit from ydb repo

Author: qyryq

src/client/persqueue_public/CMakeLists.txt

@@ -1,10 +1,12 @@
 add_subdirectory(codecs)
+add_subdirectory(impl)
 
 add_library(cpp-client-ydb_persqueue_public INTERFACE)
 
 target_link_libraries(cpp-client-ydb_persqueue_public INTERFACE
   yutil
   cpp-client-ydb_persqueue_core
+  client-ydb_persqueue_public-impl
   client-ydb_persqueue_public-codecs
 )
 

src/client/persqueue_public/impl/write_session_impl.cpp

@@ -453,18 +453,18 @@ void TWriteSessionImpl::DoConnect(const TDuration& delay, const std::string& end
         }
         ++ConnectionGeneration;
         auto subclient = Client->GetClientForEndpoint(endpoint);
-        connectionFactory = subclient->CreateWriteSessionConnectionProcessorFactory();
         auto clientContext = subclient->CreateContext();
-        ConnectionFactory = connectionFactory;
-
-        ClientContext = std::move(clientContext);
-        ServerMessage = std::make_shared<TServerMessage>();
-
-        if (!ClientContext) {
+        if (!clientContext) {
             AbortImpl();
             // Grpc and WriteSession is closing right now.
             return;
         }
+        auto prevClientContext = std::exchange(ClientContext, clientContext);
+
+        ServerMessage = std::make_shared<TServerMessage>();
+
+        connectionFactory = subclient->CreateWriteSessionConnectionProcessorFactory();
+        ConnectionFactory = connectionFactory;
 
         connectContext = ClientContext->CreateContext();
         if (delay)
@@ -485,8 +485,10 @@ void TWriteSessionImpl::DoConnect(const TDuration& delay, const std::string& end
         if (prevConnectDelayContext)
             Cancel(prevConnectDelayContext);
         Cancel(prevConnectTimeoutContext);
+        Cancel(prevClientContext);
         Y_ASSERT(connectContext);
         Y_ASSERT(connectTimeoutContext);
+
         reqSettings = TRpcRequestSettings::Make(Settings);
 
         connectCallback = [cbContext = SelfContext,