Moved commit "Fix read session correct close ut" from ydb repo

niksaveliev · Gazizonoki · commit f0c065a41251 · 2024-11-08T22:01:01.000+03:00
diff --git a/src/client/topic/ut/basic_usage_ut.cpp b/src/client/topic/ut/basic_usage_ut.cpp
@@ -624,7 +624,7 @@ Y_UNIT_TEST_SUITE(BasicUsage) {
             bool res = session->Write(message);
             UNIT_ASSERT(res);
         }
-        bool res = session->Close(TDuration::Seconds(10));
+        bool res = session->Close(TDuration::Seconds(30));
         UNIT_ASSERT(res);
 
         std::shared_ptr<NYdb::NTopic::IReadSession> ReadSession;
@@ -659,8 +659,6 @@ Y_UNIT_TEST_SUITE(BasicUsage) {
         Cerr << ">>> TEST: Session gracefully closed" << Endl;
 
         Sleep(TDuration::Seconds(5));
-
-        // UNIT_ASSERT(false);
     }
 
     Y_UNIT_TEST(ConflictingWrites) {

Original file line number	Diff line number	Diff line change
`@@ -624,7 +624,7 @@ Y_UNIT_TEST_SUITE(BasicUsage) {`
`624`	`624`	`bool res = session->Write(message);`
`625`	`625`	`UNIT_ASSERT(res);`
`626`	`626`	`}`
`627`		`- bool res = session->Close(TDuration::Seconds(10));`
	`627`	`+ bool res = session->Close(TDuration::Seconds(30));`
`628`	`628`	`UNIT_ASSERT(res);`
`629`	`629`
`630`	`630`	`std::shared_ptr<NYdb::NTopic::IReadSession> ReadSession;`
`@@ -659,8 +659,6 @@ Y_UNIT_TEST_SUITE(BasicUsage) {`
`659`	`659`	`Cerr << ">>> TEST: Session gracefully closed" << Endl;`
`660`	`660`
`661`	`661`	`Sleep(TDuration::Seconds(5));`
`662`		`-`
`663`		`- // UNIT_ASSERT(false);`
`664`	`662`	`}`
`665`	`663`
`666`	`664`	`Y_UNIT_TEST(ConflictingWrites) {`