Skip to content

Commit f1969c2

Browse files
authored
Fix SignalR Streaming example (#42281)
1 parent 031697a commit f1969c2

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/SignalR/samples/SignalRSamples/Hubs/Streaming.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ public async IAsyncEnumerable<int> AsyncEnumerableCounter(int count, double dela
1414
for (var i = 0; i < count; i++)
1515
{
1616
yield return i;
17-
await Task.Delay((int)delay);
17+
await Task.Delay(TimeSpan.FromMilliseconds(delay));
1818
}
1919
}
2020

@@ -27,7 +27,7 @@ public ChannelReader<int> ObservableCounter(int count, double delay)
2727
return observable.AsChannelReader(Context.ConnectionAborted);
2828
}
2929

30-
public ChannelReader<int> ChannelCounter(int count, int delay)
30+
public ChannelReader<int> ChannelCounter(int count, double delay)
3131
{
3232
var channel = Channel.CreateUnbounded<int>();
3333

@@ -36,7 +36,7 @@ public ChannelReader<int> ChannelCounter(int count, int delay)
3636
for (var i = 0; i < count; i++)
3737
{
3838
await channel.Writer.WriteAsync(i);
39-
await Task.Delay(delay);
39+
await Task.Delay(TimeSpan.FromMilliseconds(delay));
4040
}
4141

4242
channel.Writer.TryComplete();

0 commit comments

Comments
 (0)