@@ -54,7 +54,6 @@ public async Task WrapsSingleBreakAsync()
54
54
Assert . That ( joined . Current , Is . EqualTo ( expected [ 0 ] ) , "First one was not what was expected." ) ;
55
55
await joined . DisposeAsync ( ) ;
56
56
57
-
58
57
// ensure that the first was disposed of even though we didn't enumerate
59
58
// all the way through
60
59
Assert . IsTrue ( first . EnumeratorDisposed , "Should have been disposed of." ) ;
@@ -139,53 +138,53 @@ private IAsyncEnumerable<T> CreateJoinedAsyncEnumerable<T>(IEnumerable<IAsyncEnu
139
138
. First ( )
140
139
. Invoke ( new object [ ] { asyncEnumerables } ) ;
141
140
}
142
- }
143
-
144
- /// <summary>
145
- /// Simple class that wraps an array list for testing purposes.
146
- /// </summary>
147
- internal class AsyncEnumerableTester < T > : IAsyncEnumerable < T >
148
- {
149
- private readonly List < T > _list ;
150
- private AsyncEnumerableTesterEnumerator _enumerator ;
151
-
152
- public AsyncEnumerableTester ( List < T > wrappedList )
153
- {
154
- _list = wrappedList ;
155
- }
156
-
157
- public bool EnumeratorCreated => _enumerator != null ;
158
-
159
- public bool EnumeratorDisposed => _enumerator ? . IsDisposed == true ;
160
141
161
- public IAsyncEnumerator < T > GetAsyncEnumerator ( CancellationToken cancellationToken = default )
162
- {
163
- _enumerator = new AsyncEnumerableTesterEnumerator ( _list . GetEnumerator ( ) ) ;
164
- return _enumerator ;
165
- }
166
-
167
- private sealed class AsyncEnumerableTesterEnumerator : IAsyncEnumerator < T >
142
+ /// <summary>
143
+ /// Simple class that wraps an array list for testing purposes.
144
+ /// </summary>
145
+ private class AsyncEnumerableTester < T > : IAsyncEnumerable < T >
168
146
{
169
- private readonly IEnumerator < T > _enumerator ;
147
+ private readonly List < T > _list ;
148
+ private AsyncEnumerableTesterEnumerator _enumerator ;
170
149
171
- public AsyncEnumerableTesterEnumerator ( IEnumerator < T > enumerator )
150
+ public AsyncEnumerableTester ( List < T > wrappedList )
172
151
{
173
- _enumerator = enumerator ;
152
+ _list = wrappedList ;
174
153
}
175
154
176
- public bool IsDisposed { get ; private set ; }
155
+ public bool EnumeratorCreated => _enumerator != null ;
177
156
178
- public T Current => _enumerator . Current ;
157
+ public bool EnumeratorDisposed => _enumerator ? . IsDisposed == true ;
179
158
180
- public ValueTask < bool > MoveNextAsync ( )
159
+ public IAsyncEnumerator < T > GetAsyncEnumerator ( CancellationToken cancellationToken = default )
181
160
{
182
- return new ValueTask < bool > ( _enumerator . MoveNext ( ) ) ;
161
+ _enumerator = new AsyncEnumerableTesterEnumerator ( _list . GetEnumerator ( ) ) ;
162
+ return _enumerator ;
183
163
}
184
164
185
- public ValueTask DisposeAsync ( )
165
+ private sealed class AsyncEnumerableTesterEnumerator : IAsyncEnumerator < T >
186
166
{
187
- IsDisposed = true ;
188
- return default ;
167
+ private readonly IEnumerator < T > _enumerator ;
168
+
169
+ public AsyncEnumerableTesterEnumerator ( IEnumerator < T > enumerator )
170
+ {
171
+ _enumerator = enumerator ;
172
+ }
173
+
174
+ public bool IsDisposed { get ; private set ; }
175
+
176
+ public T Current => _enumerator . Current ;
177
+
178
+ public ValueTask < bool > MoveNextAsync ( )
179
+ {
180
+ return new ValueTask < bool > ( _enumerator . MoveNext ( ) ) ;
181
+ }
182
+
183
+ public ValueTask DisposeAsync ( )
184
+ {
185
+ IsDisposed = true ;
186
+ return default ;
187
+ }
189
188
}
190
189
}
191
190
}
0 commit comments