dev: fix flap in tests & NextResultAsync on skipping

* dev: fix flap tests (run processing ack may not be able to start on time)
* Ado.Net NextResultAsync on skipping any more messages in ExecuteScalarAsync & ExecuteNonQueryAsync (will faster and safety)

Author: KirillKurdyukov

src/Ydb.Sdk/src/Ado/YdbCommand.cs

@@ -31,7 +31,7 @@ public override async Task<int> ExecuteNonQueryAsync(CancellationToken cancellat
     {
         await using var dataReader = await ExecuteReaderAsync(cancellationToken);
 
-        while (await dataReader.ReadAsync(cancellationToken))
+        while (await dataReader.NextResultAsync(cancellationToken))
         {
         }
 
@@ -51,7 +51,7 @@ public override async Task<int> ExecuteNonQueryAsync(CancellationToken cancellat
             ? dataReader.IsDBNull(0) ? null : dataReader.GetValue(0)
             : null;
 
-        while (await dataReader.ReadAsync(cancellationToken))
+        while (await dataReader.NextResultAsync(cancellationToken))
         {
         }
 

src/Ydb.Sdk/tests/Topic/WriterUnitTests.cs

@@ -130,7 +130,8 @@ public async Task Initialize_WhenFailWriteMessage_ShouldRetryInitializeAndReturn
         Assert.Equal(PersistenceStatus.Written, (await writer.WriteAsync("abacaba")).Status);
 
         // check attempt repeated!!!
-        _mockStream.Verify(stream => stream.Write(It.IsAny<FromClient>()), Times.Exactly(3));
+        _mockStream.Verify(stream => stream.Write(It.IsAny<FromClient>()),
+            Times.AtLeast(2)); // run processing ack may not be able to start on time 
         _mockStream.Verify(stream => stream.MoveNextAsync(), Times.Exactly(3));
         _mockStream.Verify(stream => stream.Current, Times.Exactly(2));
     }
@@ -178,7 +179,8 @@ public async Task Initialize_WhenFailMoveNextAsync_ShouldRetryInitializeAndRetur
 
         // check attempt repeated!!!
         _mockStream.Verify(stream => stream.Write(It.IsAny<FromClient>()), Times.Exactly(3));
-        _mockStream.Verify(stream => stream.MoveNextAsync(), Times.Exactly(4));
+        _mockStream.Verify(stream => stream.MoveNextAsync(),
+            Times.AtLeast(3)); // run processing ack may not be able to start on time 
         _mockStream.Verify(stream => stream.Current, Times.Exactly(2));
     }