1- using System . Data ;
21using Xunit ;
32using Ydb . Sdk . Ado . Retry ;
43
@@ -11,7 +10,7 @@ public void GetDelay_WhenAttemptOne_UsesDefaultDelayDelegate()
1110 {
1211 var config = new RetryConfig
1312 {
14- DefaultDelay = ( _ , __ ) => TimeSpan . FromMilliseconds ( 100 ) ,
13+ DefaultDelay = ( _ex , _attempt ) => TimeSpan . FromMilliseconds ( 100 ) ,
1514 MaxDelay = TimeSpan . FromMilliseconds ( 500 )
1615 } ;
1716
@@ -20,7 +19,7 @@ public void GetDelay_WhenAttemptOne_UsesDefaultDelayDelegate()
2019 var delay = policy . GetDelay ( new Exception ( "test" ) , 1 ) ;
2120 Assert . Equal ( TimeSpan . FromMilliseconds ( 100 ) , delay ) ;
2221 }
23-
22+
2423 [ Fact ]
2524 public void GetDelay_WhenAttemptOne_ReturnsBaseDelay_NoJitter ( )
2625 {
@@ -49,7 +48,7 @@ public void GetDelay_WhenAttemptOne_ReturnsBaseDelay_NoJitter()
4948 public void GetDelay_WhenStatusHasOverride_ReturnsPerStatusDelay ( )
5049 {
5150 var config = new RetryConfig ( ) ;
52- config . PerStatusDelay [ StatusCode . Unavailable ] = attempt => TimeSpan . FromMilliseconds ( 123 ) ;
51+ config . PerStatusDelay [ StatusCode . Unavailable ] = _attempt => TimeSpan . FromMilliseconds ( 123 ) ;
5352 var policy = new DefaultRetryPolicy ( config ) ;
5453
5554 var ex = new YdbException ( StatusCode . Unavailable , "unavailable" ) ;
@@ -98,7 +97,7 @@ public void CanRetry_WhenUserCancelled_ReturnsFalse()
9897 var ex = new OperationCanceledException ( cts . Token ) ;
9998 Assert . False ( policy . CanRetry ( ex , isIdempotent : true ) ) ;
10099 }
101-
100+
102101 [ Fact ]
103102 public void GetDelay_WhenDelayExceedsMaxDelay_IsCappedToMaxDelay ( )
104103 {
@@ -123,22 +122,4 @@ public void CanRetry_WhenOperationCanceledWithoutToken_ReturnsFalse()
123122 var ex = new OperationCanceledException ( ) ;
124123 Assert . False ( policy . CanRetry ( ex , isIdempotent : true ) ) ;
125124 }
126-
127- private class DummyCommand : System . Data . Common . DbCommand
128- {
129- public override string CommandText { get ; set ; } = string . Empty ;
130- public override int CommandTimeout { get ; set ; }
131- public override CommandType CommandType { get ; set ; } = CommandType . Text ;
132- protected override System . Data . Common . DbConnection DbConnection { get ; set ; }
133- protected override System . Data . Common . DbParameterCollection DbParameterCollection { get ; } = null ! ;
134- protected override System . Data . Common . DbTransaction DbTransaction { get ; set ; }
135- public override bool DesignTimeVisible { get ; set ; }
136- public override UpdateRowSource UpdatedRowSource { get ; set ; }
137- public override void Cancel ( ) { }
138- public override int ExecuteNonQuery ( ) => 0 ;
139- public override object ExecuteScalar ( ) => null ! ;
140- public override void Prepare ( ) { }
141- protected override System . Data . Common . DbParameter CreateDbParameter ( ) => throw new NotImplementedException ( ) ;
142- protected override System . Data . Common . DbDataReader ExecuteDbDataReader ( CommandBehavior behavior ) => throw new NotImplementedException ( ) ;
143- }
144125}
0 commit comments