@@ -238,8 +238,8 @@ public async Task YdbDataReader_WhenCancelTokenIsCanceled_ThrowYdbException()
238238 Assert . False ( ydbDataReader . IsClosed ) ;
239239 Assert . Equal ( 1 , ydbDataReader . GetValue ( 0 ) ) ;
240240 Assert . Equal ( ConnectionState . Open , connection . State ) ;
241- Assert . Equal ( StatusCode . Cancelled , ( await Assert . ThrowsAsync < YdbException > (
242- async ( ) => await ydbDataReader . NextResultAsync ( cts . Token ) ) ) . Code ) ;
241+ Assert . Equal ( StatusCode . Cancelled ,
242+ ( await Assert . ThrowsAsync < YdbException > ( async ( ) => await ydbDataReader . NextResultAsync ( cts . Token ) ) ) . Code ) ;
243243 Assert . True ( ydbDataReader . IsClosed ) ;
244244 Assert . Equal ( ConnectionState . Broken , connection . State ) ;
245245 // ReSharper disable once MethodSupportsCancellation
@@ -254,8 +254,8 @@ public async Task YdbDataReader_WhenCancelTokenIsCanceled_ThrowYdbException()
254254 Assert . Equal ( 1 , ydbDataReader . GetValue ( 0 ) ) ;
255255 Assert . False ( ydbDataReader . IsClosed ) ;
256256
257- Assert . Equal ( StatusCode . Cancelled , ( await Assert . ThrowsAsync < YdbException > (
258- async ( ) => await ydbDataReader . NextResultAsync ( cts . Token ) ) ) . Code ) ;
257+ Assert . Equal ( StatusCode . Cancelled ,
258+ ( await Assert . ThrowsAsync < YdbException > ( async ( ) => await ydbDataReader . NextResultAsync ( cts . Token ) ) ) . Code ) ;
259259 Assert . True ( ydbDataReader . IsClosed ) ;
260260 Assert . Equal ( ConnectionState . Broken , connection . State ) ;
261261 }
@@ -268,18 +268,18 @@ public async Task ExecuteMethods_WhenCancelTokenIsCanceled_ConnectionIsBroken()
268268 using var cts = new CancellationTokenSource ( ) ;
269269 cts . Cancel ( ) ;
270270
271- Assert . Equal ( StatusCode . Cancelled , ( await Assert . ThrowsAsync < YdbException > (
272- async ( ) => await command . ExecuteReaderAsync ( cts . Token ) ) ) . Code ) ;
271+ Assert . Equal ( StatusCode . Cancelled ,
272+ ( await Assert . ThrowsAsync < YdbException > ( async ( ) => await command . ExecuteReaderAsync ( cts . Token ) ) ) . Code ) ;
273273 Assert . Equal ( ConnectionState . Broken , connection . State ) ;
274274 // ReSharper disable once MethodSupportsCancellation
275275 await connection . OpenAsync ( ) ;
276- Assert . Equal ( StatusCode . Cancelled , ( await Assert . ThrowsAsync < YdbException > (
277- async ( ) => await command . ExecuteScalarAsync ( cts . Token ) ) ) . Code ) ;
276+ Assert . Equal ( StatusCode . Cancelled ,
277+ ( await Assert . ThrowsAsync < YdbException > ( async ( ) => await command . ExecuteScalarAsync ( cts . Token ) ) ) . Code ) ;
278278 Assert . Equal ( ConnectionState . Broken , connection . State ) ;
279279 // ReSharper disable once MethodSupportsCancellation
280280 await connection . OpenAsync ( ) ;
281- Assert . Equal ( StatusCode . Cancelled , ( await Assert . ThrowsAsync < YdbException > (
282- async ( ) => await command . ExecuteNonQueryAsync ( cts . Token ) ) ) . Code ) ;
281+ Assert . Equal ( StatusCode . Cancelled ,
282+ ( await Assert . ThrowsAsync < YdbException > ( async ( ) => await command . ExecuteNonQueryAsync ( cts . Token ) ) ) . Code ) ;
283283 Assert . Equal ( ConnectionState . Broken , connection . State ) ;
284284 }
285285
0 commit comments