@@ -106,7 +106,7 @@ public async Task ClosedYdbDataReader_WhenConnectionIsClosed_ThrowException()
106106 [ Fact ]
107107 public async Task SetNulls_WhenTableAllTypes_SussesSet ( )
108108 {
109- var ydbConnection = await CreateOpenConnectionAsync ( ) ;
109+ await using var ydbConnection = await CreateOpenConnectionAsync ( ) ;
110110 var ydbCommand = ydbConnection . CreateCommand ( ) ;
111111 var tableName = "AllTypes_" + Random . Shared . Next ( ) ;
112112
@@ -270,7 +270,7 @@ public async Task ExecuteReaderAsync_WhenExecutedYdbDataReaderThenCancelTokenIsC
270270 await ydbDataReader . ReadAsync ( cts . Token ) ;
271271 Assert . Equal ( 1 , ydbDataReader . GetValue ( 0 ) ) ;
272272 Assert . True ( await ydbDataReader . NextResultAsync ( cts . Token ) ) ;
273- cts . Cancel ( ) ;
273+ await cts . CancelAsync ( ) ;
274274 await ydbDataReader . ReadAsync ( cts . Token ) ;
275275 Assert . Equal ( 1 , ydbDataReader . GetValue ( 0 ) ) ;
276276 // ReSharper disable once MethodSupportsCancellation
@@ -416,6 +416,7 @@ PRIMARY KEY (Id)
416416 await Task . WhenAll (
417417 Task . Run ( async ( ) =>
418418 {
419+ // ReSharper disable once AccessToDisposedClosure
419420 var importer = ydbConnection . BeginBulkUpsertImport ( table1 , columns ) ;
420421 var rows = Enumerable . Range ( 0 , 20 )
421422 . Select ( i => new object [ ] { i , $ "A{ i } " } )
@@ -426,6 +427,7 @@ await Task.WhenAll(
426427 } ) ,
427428 Task . Run ( async ( ) =>
428429 {
430+ // ReSharper disable once AccessToDisposedClosure
429431 var importer = ydbConnection . BeginBulkUpsertImport ( table2 , columns ) ;
430432 var rows = Enumerable . Range ( 0 , 20 )
431433 . Select ( i => new object [ ] { i , $ "B{ i } " } )
0 commit comments