* IReadOnlyCollection -> IReadOnlyList

* Update Grpc lib version
* Fixed error type: YdbException -> ReaderException
* Added new units tests

Author: KirillKurdyukov

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

@@ -59,10 +59,10 @@ public class BatchMessages<TValue>
     private readonly OffsetsRange _offsetsRange;
     private readonly long _partitionSessionId;
 
-    public IReadOnlyCollection<Message<TValue>> Batch { get; }
+    public IReadOnlyList<Message<TValue>> Batch { get; }
 
     internal BatchMessages(
-        IReadOnlyCollection<Message<TValue>> batch,
+        IReadOnlyList<Message<TValue>> batch,
         ReaderSession<TValue> readerSession,
         OffsetsRange offsetsRange,
         long partitionSessionId)

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

@@ -37,7 +37,7 @@ public PartitionSession(
     internal long PrevEndOffsetMessage { get; set; }
 
     // Each offset up to and including (committed_offset - 1) was fully processed.
-    internal long CommitedOffset { get; private set; }
+    private long CommitedOffset { get; set; }
 
     internal void RegisterCommitRequest(CommitSending commitSending)
     {

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

@@ -2,7 +2,6 @@
 using System.Threading.Channels;
 using Google.Protobuf.WellKnownTypes;
 using Microsoft.Extensions.Logging;
-using Ydb.Sdk.Ado;
 using Ydb.Topic;
 using Ydb.Topic.V1;
 using static Ydb.Topic.StreamReadMessage.Types.FromServer;
@@ -203,9 +202,9 @@ public void Dispose()
     {
         try
         {
+            _receivedMessagesChannel.Writer.TryComplete();
+            
             _disposeCts.Cancel();
-
-            _receivedMessagesChannel.Writer.Complete();
         }
         finally
         {
@@ -442,7 +441,7 @@ public async Task CommitOffsetRange(OffsetsRange offsetsRange, long partitionSes
         var tcsCommit = new TaskCompletionSource();
 
         await using var register = _lifecycleReaderSessionCts.Token.Register(
-            () => tcsCommit.TrySetException(new YdbException($"ReaderSession[{SessionId}] was deactivated"))
+            () => tcsCommit.TrySetException(new ReaderException($"ReaderSession[{SessionId}] was deactivated"))
         );
 
         var commitSending = new CommitSending(offsetsRange, tcsCommit);

src/Ydb.Sdk/src/Ydb.Sdk.csproj

@@ -26,7 +26,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="Ydb.Protos" Version="1.0.6" />
+    <PackageReference Include="Ydb.Protos" Version="1.1.0" />
     <PackageReference Include="Portable.BouncyCastle" Version="1.9.0" />
     <PackageReference Include="System.IdentityModel.Tokens.Jwt" Version="7.0.0" />
   </ItemGroup>