We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 01e8e76 commit dfa60afCopy full SHA for dfa60af
1 file changed
Open.ChannelExtensions.Tests/BasicTests.cs
@@ -334,18 +334,21 @@ public static async Task Filter(int testSize)
334
[Fact]
335
public static void PossibleSourceLoadingIssue()
336
{
337
+ const int expectedCount = 10000000;
338
int count_ = 0;
339
340
var queue = new BlockingCollection<int>();
341
var processingTask = StartProcessingTask2(queue.GetConsumingEnumerable());
342
- for (var i = 0; i < 100000000; i++)
343
+ for (var i = 0; i < expectedCount; i++)
344
queue.Add(i);
345
346
queue.CompleteAdding();
347
348
processingTask.Wait();
349
350
+ Assert.Equal(expectedCount, count_);
351
+
352
Task StartProcessingTask2(IEnumerable<int> source)
353
=> Channel.CreateUnbounded<int>()
354
.Source(source, true)
0 commit comments