@@ -423,13 +423,13 @@ public async Task ObservableGrain_AsyncEnumerable_SlowProducer()
423
423
public async Task ObservableGrain_AsyncEnumerable_SlowConsumer ( )
424
424
{
425
425
using var cts = new CancellationTokenSource ( TimeSpan . FromSeconds ( 30 ) ) ;
426
- var cleanupInterval = TimeSpan . FromMilliseconds ( 100 ) ;
426
+ var cleanupInterval = TimeSpan . FromMilliseconds ( 1_000 ) ;
427
427
var grain = GrainFactory . GetGrain < IObservableGrain > ( Guid . NewGuid ( ) ) ;
428
428
using var listener = new AsyncEnumerableGrainExtensionListener ( grain . GetGrainId ( ) , cleanupInterval ) ;
429
429
430
430
var producer = Task . Run ( async ( ) =>
431
431
{
432
- foreach ( var value in Enumerable . Range ( 0 , 5 ) )
432
+ foreach ( var value in Enumerable . Range ( 0 , 3 ) )
433
433
{
434
434
await grain . OnNext ( value . ToString ( ) ) ;
435
435
}
@@ -453,7 +453,7 @@ public async Task ObservableGrain_AsyncEnumerable_SlowConsumer()
453
453
Logger . LogInformation ( "ObservableGrain_AsyncEnumerable: {Entry}" , entry ) ;
454
454
}
455
455
456
- Assert . Equal ( 5 , values . Count ) ;
456
+ Assert . Equal ( 3 , values . Count ) ;
457
457
458
458
// Check that the enumerator is disposed
459
459
var grainCalls = await grain . GetIncomingCalls ( ) ;
@@ -464,7 +464,7 @@ public async Task ObservableGrain_AsyncEnumerable_SlowConsumer()
464
464
public async Task ObservableGrain_AsyncEnumerable_SlowConsumer_Evicted ( )
465
465
{
466
466
using var cts = new CancellationTokenSource ( TimeSpan . FromSeconds ( 30 ) ) ;
467
- var cleanupInterval = TimeSpan . FromMilliseconds ( 100 ) ;
467
+ var cleanupInterval = TimeSpan . FromMilliseconds ( 1_000 ) ;
468
468
var grain = GrainFactory . GetGrain < IObservableGrain > ( Guid . NewGuid ( ) ) ;
469
469
using var listener = new AsyncEnumerableGrainExtensionListener ( grain . GetGrainId ( ) , cleanupInterval ) ;
470
470
0 commit comments