Skip to content

Commit 5f4f5dd

Browse files
committed
changes it back into WithSubstreamsSupport
1 parent edc2f5f commit 5f4f5dd

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

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

+5-5
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ public StreamPuppet(IPublisher<int> p, TestKitBase kit)
5454

5555
public async Task ExpectNextAsync(int element) => await _probe.ExpectNextAsync(element);
5656

57-
public async Task ExpectNoMsgAsync(TimeSpan max) => await _probe.ExpectNoMsgAsync(max);
57+
public void ExpectNoMsg(TimeSpan max) => _probe.ExpectNoMsg(max);
5858

5959
public async Task ExpectCompleteAsync() => await _probe.ExpectCompleteAsync();
6060

@@ -93,7 +93,7 @@ await this.AssertAllStagesStoppedAsync(() => {
9393
{
9494
var s1 = new StreamPuppet(getSubFlow()
9595
.RunWith(Sink.AsPublisher<int>(false), Materializer), this);
96-
await masterSubscriber.ExpectNoMsgAsync(TimeSpan.FromMilliseconds(100));
96+
masterSubscriber.ExpectNoMsg(TimeSpan.FromMilliseconds(100));
9797
s1.Request(2);
9898
await s1.ExpectNextAsync(1);
9999
await s1.ExpectNextAsync(2);
@@ -102,11 +102,11 @@ await this.AssertAllStagesStoppedAsync(() => {
102102

103103
var s2 = new StreamPuppet(getSubFlow()
104104
.RunWith(Sink.AsPublisher<int>(false), Materializer), this);
105-
await masterSubscriber.ExpectNoMsgAsync(TimeSpan.FromMilliseconds(100));
105+
masterSubscriber.ExpectNoMsg(TimeSpan.FromMilliseconds(100));
106106

107107
s2.Request(1);
108-
await s2.ExpectNextAsync(3);
109-
await s2.ExpectNoMsgAsync(TimeSpan.FromMilliseconds(100));
108+
await s2.ExpectNextAsync(3);
109+
s2.ExpectNoMsg(TimeSpan.FromMilliseconds(100));
110110

111111
s2.Request(1);
112112
await s2.ExpectNextAsync(4);

0 commit comments

Comments
 (0)