fixes

Author: KirillKurdyukov

.github/workflows/tests.yml

@@ -181,7 +181,7 @@ jobs:
         uses: actions/setup-dotnet@v4
         with:
           dotnet-version: ${{ matrix.dotnet-version }}
-      - name: Run ADO.NET examples
+      - name: Run ADO.NET example
         run: |
           docker cp ydb-local:/ydb_certs/ca.pem ~/
           cd ./examples/src/AdoNet
@@ -190,3 +190,7 @@ jobs:
         run: |
           cd ./examples/src/DapperExample
           dotnet run
+      - name: YDB Topic example
+        run: |
+          cd ./examples/src/Topic
+          dotnet run

CHANGELOG.md

@@ -1,3 +1,7 @@
+- Fixed Writer: possible creation of a session after `DisposeAsync()`, which this could happen when there are canceled tasks in `InFlightMessages`.
+- Dev: `Writer.MoveNext()` changed exception on cancelToken from `WriterException` to `TaskCanceledException`.
+- Dev: changed log level from `Warning` to `Information` in `(Reader / Writer).Initialize()` when it is disposed.
+
 ## v0.15.0
 - Dev: added `ValueTask<string?> GetAuthInfoAsync()` in ICredentialProvider.
 - Feat: `Writer.DisposeAsync()` waits for all in-flight messages to complete.

examples/src/Topic/Program.cs

@@ -63,7 +63,7 @@ await topicClient.CreateTopic(new CreateTopicSettings
             var message = await reader.ReadAsync(readerCts.Token);
 
             logger.LogInformation("Received message: [{MessageData}]", message.Data);
-            
+
             try
             {
                 await message.CommitAsync();

src/Ydb.Sdk/src/Services/Topic/Reader/Reader.cs

@@ -96,7 +96,7 @@ private async Task Initialize()
         {
             if (_disposeCts.IsCancellationRequested)
             {
-                _logger.LogInformation("Reader writer is canceled because it has been disposed");
+                _logger.LogInformation("Initialize reader is canceled because it has been disposed");
 
                 return;
             }