Skip to content

Commit 2564c51

Browse files
harden QueueSinkSpec (#7566)
No need to be so prescriptive about wait times
1 parent 2d5025a commit 2564c51

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

src/core/Akka.Streams.Tests/Dsl/QueueSinkSpec.cs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -233,9 +233,8 @@ await this.AssertAllStagesStoppedAsync(async() => {
233233
await ExpectMsgAsync(Option<int>.Create(2));
234234

235235
sub.SendComplete();
236-
var future = queue.PullAsync();
237-
future.Wait(_pause).Should().BeTrue();
238-
future.Result.Should().Be(Option<int>.None);
236+
var result = await queue.PullAsync();
237+
result.Should().Be(Option<int>.None);
239238
}, _materializer);
240239
}
241240

0 commit comments

Comments
 (0)