Skip to content

Commit 9eec5a9

Browse files
akarnokdakarnokd
committed
Add CancellationToken support (forced)
1 parent ba841d9 commit 9eec5a9

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

87 files changed

+748
-350
lines changed

‎async-enumerable-dotnet-benchmark/Program.cs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ static void Main(string[] args)
3030
var list = TimeSequence(0, 200, 400, 600)
3131
.ConcatMapEager(v => AsyncEnumerable.Timer(TimeSpan.FromMilliseconds(100)))
3232
.Take(1)
33-
.GetAsyncEnumerator();
33+
.GetAsyncEnumerator(default);
3434

3535
try
3636
{

‎async-enumerable-dotnet-test/AmbTest.cs‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,7 @@ public async void First_Win_Sync()
9696
AsyncEnumerable.Range(6, 5)
9797
.DoOnNext(async v => { await ttr.CreateCompleteTask(1000); })
9898
)
99-
.GetAsyncEnumerator()
99+
.GetAsyncEnumerator(default)
100100
;
101101

102102
try
@@ -134,7 +134,7 @@ public async void Second_Win_Sync()
134134
AsyncEnumerable.Range(6, 5)
135135
.DoOnNext(async v => { await ttr.CreateCompleteTask(500); })
136136
)
137-
.GetAsyncEnumerator()
137+
.GetAsyncEnumerator(default)
138138
;
139139

140140
try

‎async-enumerable-dotnet-test/EmptyTest.cs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ await AsyncEnumerable.Empty<int>()
1919
[Fact]
2020
public void Current()
2121
{
22-
Assert.Equal(0, AsyncEnumerable.Empty<int>().GetAsyncEnumerator().Current);
22+
Assert.Equal(0, AsyncEnumerable.Empty<int>().GetAsyncEnumerator(default).Current);
2323
}
2424
}
2525
}

‎async-enumerable-dotnet-test/ErrorTest.cs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ public class ErrorTest
1313
[Fact]
1414
public async void Calls()
1515
{
16-
var en = AsyncEnumerable.Error<int>(new InvalidOperationException()).GetAsyncEnumerator();
16+
var en = AsyncEnumerable.Error<int>(new InvalidOperationException()).GetAsyncEnumerator(default);
1717

1818
try
1919
{

‎async-enumerable-dotnet-test/FromObservableTest.cs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ public async void Long()
3535
var result = new ObservableRange(1, n).ToAsyncEnumerable();
3636

3737
var expected = 1;
38-
var en = result.GetAsyncEnumerator();
38+
var en = result.GetAsyncEnumerator(default);
3939
try
4040
{
4141
while (await en.MoveNextAsync())

‎async-enumerable-dotnet-test/IgnoreElementsTest.cs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ await AsyncEnumerable.Empty<int>()
2929
public void Current()
3030
{
3131
Assert.Equal(0, AsyncEnumerable.Range(1, 5)
32-
.IgnoreElements().GetAsyncEnumerator().Current);
32+
.IgnoreElements().GetAsyncEnumerator(default).Current);
3333
}
3434
}
3535
}

‎async-enumerable-dotnet-test/LatestTest.cs‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ public class LatestTest
1414
[Fact]
1515
public async void Skip_All()
1616
{
17-
var en = AsyncEnumerable.Range(1, 5).Latest().GetAsyncEnumerator();
17+
var en = AsyncEnumerable.Range(1, 5).Latest().GetAsyncEnumerator(default);
1818

1919
try
2020
{
@@ -36,7 +36,7 @@ public async void Skip_All()
3636
public async void Normal()
3737
{
3838
var push = new MulticastAsyncEnumerable<int>();
39-
var en = push.Latest().GetAsyncEnumerator();
39+
var en = push.Latest().GetAsyncEnumerator(default);
4040

4141
try
4242
{

‎async-enumerable-dotnet-test/MulticastAsyncEnumerableTest.cs‎

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ public async void Normal_One_Consumer()
4444
{
4545
var push = new MulticastAsyncEnumerable<int>();
4646

47-
var en1 = push.GetAsyncEnumerator();
47+
var en1 = push.GetAsyncEnumerator(default);
4848

4949
var task = Task.Run(async () =>
5050
{
@@ -65,7 +65,7 @@ public async void Error_One_Consumer()
6565
{
6666
var push = new MulticastAsyncEnumerable<int>();
6767

68-
var en1 = push.GetAsyncEnumerator();
68+
var en1 = push.GetAsyncEnumerator(default);
6969

7070
var task = Task.Run(async () =>
7171
{
@@ -86,14 +86,14 @@ public async void Normal_2_Consumers()
8686
{
8787
var push = new MulticastAsyncEnumerable<int>();
8888

89-
var en1 = push.GetAsyncEnumerator();
89+
var en1 = push.GetAsyncEnumerator(default);
9090

9191
var task1 = Task.Run(async () =>
9292
{
9393
await en1.AssertResult(1, 2, 3, 4, 5);
9494
});
9595

96-
var en2 = push.GetAsyncEnumerator();
96+
var en2 = push.GetAsyncEnumerator(default);
9797
var task2 = Task.Run(async () =>
9898
{
9999
await en2.AssertResult(1, 2, 3, 4, 5);
@@ -114,10 +114,10 @@ public async void Error_2_Consumers()
114114
{
115115
var push = new MulticastAsyncEnumerable<int>();
116116

117-
var en1 = push.GetAsyncEnumerator();
117+
var en1 = push.GetAsyncEnumerator(default);
118118

119119

120-
var en2 = push.GetAsyncEnumerator();
120+
var en2 = push.GetAsyncEnumerator(default);
121121

122122
var task1 = Task.Run(async () =>
123123
{
@@ -143,14 +143,14 @@ public async void Normal_2_Consumers_One_Take()
143143
{
144144
var push = new MulticastAsyncEnumerable<int>();
145145

146-
var en1 = push.Take(3).GetAsyncEnumerator();
146+
var en1 = push.Take(3).GetAsyncEnumerator(default);
147147

148148
var task1 = Task.Run(async () =>
149149
{
150150
await en1.AssertResult(1, 2, 3);
151151
});
152152

153-
var en2 = push.GetAsyncEnumerator();
153+
var en2 = push.GetAsyncEnumerator(default);
154154
var task2 = Task.Run(async () =>
155155
{
156156
await en2.AssertResult(1, 2, 3, 4, 5);
@@ -173,7 +173,7 @@ public async void HasConsumers()
173173

174174
Assert.False(push.HasConsumers);
175175

176-
var en = push.GetAsyncEnumerator();
176+
var en = push.GetAsyncEnumerator(default);
177177

178178
Assert.True(push.HasConsumers);
179179

@@ -189,7 +189,7 @@ public async void Complete()
189189

190190
Assert.False(push.HasConsumers);
191191

192-
var en = push.GetAsyncEnumerator();
192+
var en = push.GetAsyncEnumerator(default);
193193

194194
Assert.True(push.HasConsumers);
195195

‎async-enumerable-dotnet-test/NeverTest.cs‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,9 +22,9 @@ await AsyncEnumerable.Never<int>()
2222
[Fact]
2323
public void Normal()
2424
{
25-
var en = AsyncEnumerable.Never<int>().GetAsyncEnumerator();
25+
var en = AsyncEnumerable.Never<int>().GetAsyncEnumerator(default);
2626

27-
Assert.Equal(0, AsyncEnumerable.Never<int>().GetAsyncEnumerator().Current);
27+
Assert.Equal(0, AsyncEnumerable.Never<int>().GetAsyncEnumerator(default).Current);
2828

2929
// no await as the test would never end otherwise
3030

‎async-enumerable-dotnet-test/ReplayAsyncEnumerableTest.cs‎

Lines changed: 20 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ public async void Unbounded_One_Consumer()
4848
{
4949
var push = new ReplayAsyncEnumerable<int>();
5050

51-
var en1 = push.GetAsyncEnumerator();
51+
var en1 = push.GetAsyncEnumerator(default);
5252

5353
var task1 = Task.Run(async () =>
5454
{
@@ -69,7 +69,7 @@ public async void Unbounded_One_Consumer_Error()
6969
{
7070
var push = new ReplayAsyncEnumerable<int>();
7171

72-
var en1 = push.GetAsyncEnumerator();
72+
var en1 = push.GetAsyncEnumerator(default);
7373

7474
var task1 = Task.Run(async () =>
7575
{
@@ -90,8 +90,8 @@ public async void Unbounded_2_Consumers()
9090
{
9191
var push = new ReplayAsyncEnumerable<int>();
9292

93-
var en1 = push.GetAsyncEnumerator();
94-
var en2 = push.GetAsyncEnumerator();
93+
var en1 = push.GetAsyncEnumerator(default);
94+
var en2 = push.GetAsyncEnumerator(default);
9595

9696
var task1 = Task.Run(async () =>
9797
{
@@ -117,8 +117,8 @@ public async void Unbounded_2_Consumers_Error()
117117
{
118118
var push = new ReplayAsyncEnumerable<int>();
119119

120-
var en1 = push.GetAsyncEnumerator();
121-
var en2 = push.GetAsyncEnumerator();
120+
var en1 = push.GetAsyncEnumerator(default);
121+
var en2 = push.GetAsyncEnumerator(default);
122122

123123
var task1 = Task.Run(async () =>
124124
{
@@ -200,7 +200,7 @@ public async void Sized_One_Consumer()
200200
{
201201
var push = new ReplayAsyncEnumerable<int>(10);
202202

203-
var en1 = push.GetAsyncEnumerator();
203+
var en1 = push.GetAsyncEnumerator(default);
204204

205205
var task1 = Task.Run(async () =>
206206
{
@@ -221,7 +221,7 @@ public async void Sized_One_Consumer_Error()
221221
{
222222
var push = new ReplayAsyncEnumerable<int>(10);
223223

224-
var en1 = push.GetAsyncEnumerator();
224+
var en1 = push.GetAsyncEnumerator(default);
225225

226226
var task1 = Task.Run(async () =>
227227
{
@@ -242,8 +242,8 @@ public async void Sized_2_Consumers()
242242
{
243243
var push = new ReplayAsyncEnumerable<int>(10);
244244

245-
var en1 = push.GetAsyncEnumerator();
246-
var en2 = push.GetAsyncEnumerator();
245+
var en1 = push.GetAsyncEnumerator(default);
246+
var en2 = push.GetAsyncEnumerator(default);
247247

248248
var task1 = Task.Run(async () =>
249249
{
@@ -269,8 +269,8 @@ public async void Sized_2_Consumers_Error()
269269
{
270270
var push = new ReplayAsyncEnumerable<int>(10);
271271

272-
var en1 = push.GetAsyncEnumerator();
273-
var en2 = push.GetAsyncEnumerator();
272+
var en1 = push.GetAsyncEnumerator(default);
273+
var en2 = push.GetAsyncEnumerator(default);
274274

275275
var task1 = Task.Run(async () =>
276276
{
@@ -376,7 +376,7 @@ public async void TimedSized_One_Consumer()
376376
{
377377
var push = new ReplayAsyncEnumerable<int>(10, TimeSpan.FromHours(1));
378378

379-
var en1 = push.GetAsyncEnumerator();
379+
var en1 = push.GetAsyncEnumerator(default);
380380

381381
var task1 = Task.Run(async () =>
382382
{
@@ -397,7 +397,7 @@ public async void TimedSized_One_Consumer_Error()
397397
{
398398
var push = new ReplayAsyncEnumerable<int>(10, TimeSpan.FromHours(1));
399399

400-
var en1 = push.GetAsyncEnumerator();
400+
var en1 = push.GetAsyncEnumerator(default);
401401

402402
var task1 = Task.Run(async () =>
403403
{
@@ -418,8 +418,8 @@ public async void TimedSized_2_Consumers()
418418
{
419419
var push = new ReplayAsyncEnumerable<int>(10, TimeSpan.FromHours(1));
420420

421-
var en1 = push.GetAsyncEnumerator();
422-
var en2 = push.GetAsyncEnumerator();
421+
var en1 = push.GetAsyncEnumerator(default);
422+
var en2 = push.GetAsyncEnumerator(default);
423423

424424
var task1 = Task.Run(async () =>
425425
{
@@ -445,8 +445,8 @@ public async void TimedSized_2_Consumers_Error()
445445
{
446446
var push = new ReplayAsyncEnumerable<int>(10, TimeSpan.FromHours(1));
447447

448-
var en1 = push.GetAsyncEnumerator();
449-
var en2 = push.GetAsyncEnumerator();
448+
var en1 = push.GetAsyncEnumerator(default);
449+
var en2 = push.GetAsyncEnumerator(default);
450450

451451
var task1 = Task.Run(async () =>
452452
{
@@ -684,7 +684,7 @@ public async void HasConsumers()
684684

685685
Assert.False(push.HasConsumers);
686686

687-
var en = push.GetAsyncEnumerator();
687+
var en = push.GetAsyncEnumerator(default);
688688

689689
Assert.True(push.HasConsumers);
690690

@@ -700,7 +700,7 @@ public async void Complete()
700700

701701
Assert.False(push.HasConsumers);
702702

703-
var en = push.GetAsyncEnumerator();
703+
var en = push.GetAsyncEnumerator(default);
704704

705705
Assert.True(push.HasConsumers);
706706

0 commit comments

Comments
 (0)