change ct in Flush

Author: LiamHamsters

src/Ydb.Sdk/src/Ado/BulkUpsert/BulkUpsertImporter.cs

@@ -48,7 +48,7 @@ public async ValueTask AddRowAsync(object?[] values)
 
         if (_currentBytes + rowSize > _maxBytes && _rows.Count > 0)
         {
-            await FlushAsync(_cancellationToken);
+            await FlushAsync();
         }
 
         _rows.Add(protoStruct);
@@ -67,7 +67,7 @@ public async ValueTask AddRowAsync(object?[] values)
         };
     }
 
-    public async ValueTask FlushAsync(CancellationToken cancellationToken = default)
+    public async ValueTask FlushAsync()
     {
         if (_rows.Count == 0) return;
         if (_structType == null)
@@ -84,7 +84,7 @@ public async ValueTask FlushAsync(CancellationToken cancellationToken = default)
         var resp = await _driver.UnaryCall(
             TableService.BulkUpsertMethod,
             req,
-            new GrpcRequestSettings { CancellationToken = cancellationToken }
+            new GrpcRequestSettings { CancellationToken = _cancellationToken }
         ).ConfigureAwait(false);
 
         var operation = resp.Operation;

src/Ydb.Sdk/src/Ado/BulkUpsert/IBulkUpsertImporter.cs

@@ -2,6 +2,7 @@ namespace Ydb.Sdk.Ado.BulkUpsert;
 
 public interface IBulkUpsertImporter
 {
-    ValueTask AddRowAsync(object?[] rows);
-    ValueTask FlushAsync(CancellationToken cancellationToken = default);
+    ValueTask AddRowAsync(object?[] row);
+
+    ValueTask FlushAsync();
 }