Increase timeout value to avoid timeout failure (#5021)

Co-authored-by: Aaron Stannard <aaron@petabridge.com>
akkadotnet · May 18, 2021 · 0869e49 · 0869e49
1 parent 3f6182c
commit 0869e49
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/core/Akka.Streams.Tests/Dsl/KeepAliveConcatSpec.cs b/src/core/Akka.Streams.Tests/Dsl/KeepAliveConcatSpec.cs
@@ -13,11 +13,16 @@
 using Akka.Streams.TestKit.Tests;
 using FluentAssertions;
 using Xunit;
+using Xunit.Abstractions;
 
 namespace Akka.Streams.Tests.Dsl
 {
     public class KeepAliveConcatSpec : Akka.TestKit.Xunit2.TestKit
     {
+        public KeepAliveConcatSpec(ITestOutputHelper output)
+            : base(output: output)
+        { }
+
         private readonly Source<IEnumerable<int>, NotUsed> _sampleSource = Source.From(Enumerable.Range(1, 10).Grouped(3));
 
         private IEnumerable<IEnumerable<int>> Expand(IEnumerable<int> lst)
@@ -52,7 +57,7 @@ public void KeepAliveConcat_should_emit_elements_periodically_after_silent_perio
                 .Grouped(1000)
                 .RunWith(Sink.First<IEnumerable<IEnumerable<int>>>(), Sys.Materializer());
 
-            t.AwaitResult()
+            t.AwaitResult(TimeSpan.FromSeconds(6))
                 .SelectMany(x => x)
                 .Should().BeEquivalentTo(Enumerable.Range(1, 10), o => o.WithStrictOrdering());
         }