feat: impl AsyncDispose Reader.cs

KirillKurdyukov · KirillKurdyukov · commit 1a10e2dd933c · 2025-03-05T13:21:20.000+03:00
diff --git a/src/Ydb.Sdk/src/Services/Topic/Reader/Reader.cs b/src/Ydb.Sdk/src/Services/Topic/Reader/Reader.cs
@@ -564,6 +564,8 @@ public override async ValueTask DisposeAsync()
             await _runProcessingStreamRequest;
             await Stream.RequestStreamComplete();
             await _runProcessingStreamResponse; // waiting all ack's commits
+            
+            _lifecycleReaderSessionCts.Cancel();
         }
         finally
         {

Original file line number	Diff line number	Diff line change
`@@ -564,6 +564,8 @@ public override async ValueTask DisposeAsync()`
`564`	`564`	`await _runProcessingStreamRequest;`
`565`	`565`	`await Stream.RequestStreamComplete();`
`566`	`566`	`await _runProcessingStreamResponse; // waiting all ack's commits`
	`567`	`+`
	`568`	`+ _lifecycleReaderSessionCts.Cancel();`
`567`	`569`	`}`
`568`	`570`	`finally`
`569`	`571`	`{`