From a626bd9e2902cde1572ad055429fa098f2ec9bb0 Mon Sep 17 00:00:00 2001 From: Aaron Stannard Date: Wed, 6 Jul 2022 08:58:00 -0500 Subject: [PATCH] harden HubSpec duration (#6030) Needed to boost time to process 20,000 elements with buffer size =1 from 3 cumulative seconds to 300. On low quality AzDo machines there's no telling what delays we'll hit. --- src/core/Akka.Streams.Tests/Dsl/HubSpec.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/core/Akka.Streams.Tests/Dsl/HubSpec.cs b/src/core/Akka.Streams.Tests/Dsl/HubSpec.cs index 9a7e31bbd7d..d75f6976eb2 100644 --- a/src/core/Akka.Streams.Tests/Dsl/HubSpec.cs +++ b/src/core/Akka.Streams.Tests/Dsl/HubSpec.cs @@ -191,7 +191,7 @@ public async Task MergeHub_must_work_with_long_streams_when_buffer_size_is_1() Source.From(Enumerable.Range(10001, 10000)).RunWith(sink, Materializer); await probe.RequestAsync(int.MaxValue); - var result = await probe.ExpectNextNAsync(20000, 3.Seconds()).ToListAsync(); + var result = await probe.ExpectNextNAsync(20000, 300.Seconds()).ToListAsync(); result.OrderBy(x => x).Should().BeEquivalentTo(Enumerable.Range(1, 20000)); }, Materializer); }