@@ -349,7 +349,7 @@ public async Task<bool> SucceedFunction(
349
349
IReadOnlyList < StoredMessage > ? messages ,
350
350
ComplimentaryState complimentaryState )
351
351
{
352
- var suspendCommand = _sqlGenerator . SucceedFunction ( storedId , result , timestamp , expectedEpoch ) ;
352
+ var succeedCommand = _sqlGenerator . SucceedFunction ( storedId , result , timestamp , expectedEpoch ) ;
353
353
var effectsCommand = effects == null
354
354
? null
355
355
: _sqlGenerator . UpsertEffects ( effects ) ;
@@ -360,14 +360,14 @@ public async Task<bool> SucceedFunction(
360
360
await using var conn = await CreateOpenConnection ( _connectionString ) ;
361
361
if ( effects == null && messages == null )
362
362
{
363
- await using var command = suspendCommand . ToSqlCommand ( conn ) ;
363
+ await using var command = succeedCommand . ToSqlCommand ( conn ) ;
364
364
var affectedRows = await command . ExecuteNonQueryAsync ( ) ;
365
365
return affectedRows == 1 ;
366
366
}
367
367
else
368
368
{
369
369
await using var command = StoreCommand . Merge (
370
- messagesCommand . Append ( effectsCommand ) . Append ( suspendCommand )
370
+ messagesCommand . Append ( effectsCommand ) . Append ( succeedCommand )
371
371
) ! . ToSqlCommand ( conn ) ;
372
372
var affectedRows = await command . ExecuteNonQueryAsync ( ) ;
373
373
return affectedRows == 1 + ( effects ? . Count ?? 0 ) + ( messages ? . Count ?? 0 ) ;
@@ -384,7 +384,7 @@ public async Task<bool> PostponeFunction(
384
384
IReadOnlyList < StoredMessage > ? messages ,
385
385
ComplimentaryState complimentaryState )
386
386
{
387
- var suspendCommand = _sqlGenerator
387
+ var postponeCommand = _sqlGenerator
388
388
. PostponeFunction ( storedId , postponeUntil , timestamp , ignoreInterrupted , expectedEpoch ) ;
389
389
var effectsCommand = effects == null
390
390
? null
@@ -396,14 +396,14 @@ public async Task<bool> PostponeFunction(
396
396
await using var conn = await CreateOpenConnection ( _connectionString ) ;
397
397
if ( effects == null && messages == null )
398
398
{
399
- await using var command = suspendCommand . ToSqlCommand ( conn ) ;
399
+ await using var command = postponeCommand . ToSqlCommand ( conn ) ;
400
400
var affectedRows = await command . ExecuteNonQueryAsync ( ) ;
401
401
return affectedRows == 1 ;
402
402
}
403
403
else
404
404
{
405
405
await using var command = StoreCommand . Merge (
406
- messagesCommand . Append ( effectsCommand ) . Append ( suspendCommand )
406
+ messagesCommand . Append ( effectsCommand ) . Append ( postponeCommand )
407
407
) ! . ToSqlCommand ( conn ) ;
408
408
var affectedRows = await command . ExecuteNonQueryAsync ( ) ;
409
409
return affectedRows == 1 + ( effects ? . Count ?? 0 ) + ( messages ? . Count ?? 0 ) ;
0 commit comments