@@ -16,13 +16,13 @@ namespace async_enumerable_dotnet_test
1616{
1717 internal static class TestHelper
1818 {
19- public static ValueTask AssertResult < T > ( this IAsyncEnumerable < T > source , params T [ ] values )
19+ public static ValueTask AssertResult < T > ( this async_enumerable_dotnet . IAsyncEnumerable < T > source , params T [ ] values )
2020 {
2121 return AssertResult ( source . GetAsyncEnumerator ( ) , values ) ;
2222 }
2323
2424 // ReSharper disable once ParameterOnlyUsedForPreconditionCheck.Global
25- public static async ValueTask AssertResult < T > ( this IAsyncEnumerator < T > source , params T [ ] values )
25+ public static async ValueTask AssertResult < T > ( this async_enumerable_dotnet . IAsyncEnumerator < T > source , params T [ ] values )
2626 {
2727 var main = default ( Exception ) ;
2828 var dispose = default ( Exception ) ;
@@ -68,18 +68,18 @@ public static async ValueTask AssertResult<T>(this IAsyncEnumerator<T> source, p
6868 }
6969 }
7070
71- public static async ValueTask AssertThen < T > ( this IAsyncEnumerable < T > source , Action < IList < T > > outcomeHandler )
71+ public static async ValueTask AssertThen < T > ( this async_enumerable_dotnet . IAsyncEnumerable < T > source , Action < IList < T > > outcomeHandler )
7272 {
7373 var list = await source . ToListAsync ( ) ;
7474 outcomeHandler ( list ) ;
7575 }
7676
77- public static ValueTask AssertResultSet < T > ( this IAsyncEnumerable < T > source , params T [ ] values )
77+ public static ValueTask AssertResultSet < T > ( this async_enumerable_dotnet . IAsyncEnumerable < T > source , params T [ ] values )
7878 {
7979 return AssertResultSet ( source , EqualityComparer < T > . Default , values ) ;
8080 }
8181
82- public static async ValueTask AssertResultSet < T > ( this IAsyncEnumerable < T > source , IEqualityComparer < T > comparer , params T [ ] values )
82+ public static async ValueTask AssertResultSet < T > ( this async_enumerable_dotnet . IAsyncEnumerable < T > source , IEqualityComparer < T > comparer , params T [ ] values )
8383 {
8484 var set = new HashSet < T > ( values , comparer ) ;
8585 var en = source . GetAsyncEnumerator ( ) ;
@@ -121,13 +121,13 @@ private static string AsString(object obj)
121121 return obj != null ? obj . ToString ( ) : "null" ;
122122 }
123123
124- public static ValueTask AssertFailure < T > ( this IAsyncEnumerable < T > source , Type exception , params T [ ] values )
124+ public static ValueTask AssertFailure < T > ( this async_enumerable_dotnet . IAsyncEnumerable < T > source , Type exception , params T [ ] values )
125125 {
126126 return AssertFailure ( source . GetAsyncEnumerator ( ) , exception , values ) ;
127127 }
128128
129129 // ReSharper disable once ParameterOnlyUsedForPreconditionCheck.Global
130- public static async ValueTask AssertFailure < T > ( this IAsyncEnumerator < T > source , Type exception ,
130+ public static async ValueTask AssertFailure < T > ( this async_enumerable_dotnet . IAsyncEnumerator < T > source , Type exception ,
131131 params T [ ] values )
132132 {
133133 var idx = 0 ;
@@ -164,7 +164,7 @@ public static async ValueTask AssertFailure<T>(this IAsyncEnumerator<T> source,
164164 /// </summary>
165165 /// <param name="timestamps">The params array of timestamps.</param>
166166 /// <returns>The new IAsyncEnumerable sequence.</returns>
167- internal static IAsyncEnumerable < long > TimeSequence ( params long [ ] timestamps )
167+ internal static async_enumerable_dotnet . IAsyncEnumerable < long > TimeSequence ( params long [ ] timestamps )
168168 {
169169 return AsyncEnumerable . FromArray ( timestamps )
170170 . FlatMap ( v => AsyncEnumerable . Timer ( TimeSpan . FromMilliseconds ( v ) ) . Map ( w => v ) ) ;
@@ -177,7 +177,7 @@ internal static IAsyncEnumerable<long> TimeSequence(params long[] timestamps)
177177 /// <param name="error">Th error to append</param>
178178 /// <typeparam name="TSource">The element type of the sequence</typeparam>
179179 /// <returns>The new IAsyncEnumerable instance.</returns>
180- internal static IAsyncEnumerable < TSource > WithError < TSource > ( this IAsyncEnumerable < TSource > source , Exception error )
180+ internal static async_enumerable_dotnet . IAsyncEnumerable < TSource > WithError < TSource > ( this async_enumerable_dotnet . IAsyncEnumerable < TSource > source , Exception error )
181181 {
182182 return source . ConcatWith ( AsyncEnumerable . Error < TSource > ( error ) ) ;
183183 }
0 commit comments