delete block rpc calls

Author: KirillKurdyukov

src/Ydb.Sdk/tests/Ado/YdbCommandTests.cs

@@ -8,8 +8,6 @@
 
 namespace Ydb.Sdk.Tests.Ado;
 
-[Collection("YdbCommandTests")]
-[CollectionDefinition("YdbCommandTests isolation test", DisableParallelization = true)]
 public class YdbCommandTests : YdbAdoNetFixture
 {
     public YdbCommandTests(YdbFactoryFixture fixture) : base(fixture)
@@ -18,9 +16,9 @@ public YdbCommandTests(YdbFactoryFixture fixture) : base(fixture)
 
     [Theory]
     [ClassData(typeof(YdbParameterTests.TestDataGenerator))]
-    public void ExecuteScalarAsync_WhenSetYdbParameter_ReturnThisValue<T>(YdbParameterTests.Data<T> data)
+    public async Task ExecuteScalarAsync_WhenSetYdbParameter_ReturnThisValue<T>(YdbParameterTests.Data<T> data)
     {
-        using var connection = CreateOpenConnection();
+        await using var connection = await CreateOpenConnectionAsync();
         var dbCommand = connection.CreateCommand();
         dbCommand.CommandText = "SELECT @var as var;";
 
@@ -34,7 +32,7 @@ public void ExecuteScalarAsync_WhenSetYdbParameter_ReturnThisValue<T>(YdbParamet
 
         dbCommand.Parameters.Add(dbParameter);
 
-        Assert.Equal(data.Expected, dbCommand.ExecuteScalar());
+        Assert.Equal(data.Expected, await dbCommand.ExecuteScalarAsync());
         var ydbDataReader = dbCommand.ExecuteReader();
         Assert.Equal(1, ydbDataReader.FieldCount);
         Assert.Equal("var", ydbDataReader.GetName(0));
@@ -43,7 +41,7 @@ public void ExecuteScalarAsync_WhenSetYdbParameter_ReturnThisValue<T>(YdbParamet
             Assert.Equal(typeof(T), ydbDataReader.GetFieldType(0));
         }
 
-        while (ydbDataReader.Read())
+        while (await ydbDataReader.NextResultAsync())
         {
         }
     }
@@ -70,14 +68,14 @@ public void ExecuteScalarAsync_WhenSetYdbParameterThenPrepare_ReturnThisValue<T>
 
     [Theory]
     [ClassData(typeof(YdbParameterTests.TestDataGenerator))]
-    public void ExecuteScalarAsync_WhenDbTypeIsObject_ReturnThisValue<T>(YdbParameterTests.Data<T> data)
+    public async Task ExecuteScalarAsync_WhenDbTypeIsObject_ReturnThisValue<T>(YdbParameterTests.Data<T> data)
     {
         if (data.IsNullable)
         {
             return;
         }
 
-        using var connection = CreateOpenConnection();
+        await using var connection = await CreateOpenConnectionAsync();
         var dbCommand = connection.CreateCommand();
         dbCommand.CommandText = "SELECT @var;";
 
@@ -89,11 +87,11 @@ public void ExecuteScalarAsync_WhenDbTypeIsObject_ReturnThisValue<T>(YdbParamete
         };
         dbCommand.Parameters.Add(dbParameter);
 
-        Assert.Equal(data.Expected, dbCommand.ExecuteScalar());
+        Assert.Equal(data.Expected, await dbCommand.ExecuteScalarAsync());
     }
 
     [Fact]
-    public void ExecuteScalarAsync_WhenNoDbTypeParameter_ReturnThisValue()
+    public async Task ExecuteScalarAsync_WhenNoDbTypeParameter_ReturnThisValue()
     {
         const string simpleJson = @"{""a"":""b""}";
 
@@ -110,7 +108,7 @@ public void ExecuteScalarAsync_WhenNoDbTypeParameter_ReturnThisValue()
                 Encoding.ASCII.GetBytes("{type=\"yson\"}"))
         };
 
-        using var connection = CreateOpenConnection();
+        await using var connection = await CreateOpenConnectionAsync();
         var dbCommand = connection.CreateCommand();
         dbCommand.CommandText = "SELECT @var;";
 
@@ -122,7 +120,7 @@ public void ExecuteScalarAsync_WhenNoDbTypeParameter_ReturnThisValue()
                 ParameterName = "@var",
                 Value = arg.YdbValue
             });
-            Assert.Equal(arg.Expected, dbCommand.ExecuteScalar());
+            Assert.Equal(arg.Expected, await dbCommand.ExecuteScalarAsync());
         }
     }
 

src/Ydb.Sdk/tests/Ado/YdbDataSourceTests.cs

@@ -6,8 +6,6 @@
 
 namespace Ydb.Sdk.Tests.Ado;
 
-[Collection("YdbDataSourceTests")]
-[CollectionDefinition("YdbDataSourceTests isolation test", DisableParallelization = true)]
 public class YdbDataSourceTests : YdbAdoNetFixture
 {
     private const int SelectedCount = 100;
@@ -16,11 +14,11 @@ public class YdbDataSourceTests : YdbAdoNetFixture
 
     public YdbDataSourceTests(YdbFactoryFixture fixture) : base(fixture)
     {
-        _dataSource = new YdbDataSource($"{Fixture.ConnectionString};MaxSessionPool=10");
+        _dataSource = new YdbDataSource(Fixture.ConnectionString);
     }
 
     [Fact]
-    public void OpenConnectionAsync_WhenMaxSessionPool10_ReturnOpenConnection()
+    public async Task OpenConnectionAsync_WhenMaxSessionPool10_ReturnOpenConnection()
     {
         var tasks = new Task[SelectedCount];
         for (var i = 0; i < SelectedCount; i++)
@@ -33,9 +31,7 @@ public void OpenConnectionAsync_WhenMaxSessionPool10_ReturnOpenConnection()
             });
         }
 
-#pragma warning disable xUnit1031
-        Task.WaitAll(tasks);
-#pragma warning restore xUnit1031
+        await Task.WhenAll(tasks);
     }
 
     [Fact]