Remove custom IAsyncEnumerable type to use the standard one.

Author: akarnokd

README.md

@@ -1,6 +1,6 @@
 # async-enumerable-dotnet
 
-Experimental operators for C# 8 [`IAsyncEnumerable`s](https://github.com/dotnet/corefx/issues/32640).
+Experimental operators for C# 8 [`IAsyncEnumerable`s](https://docs.microsoft.com/en-us/dotnet/api/system.collections.generic.iasyncenumerable-1?view=dotnet-plat-ext-3.0).
 
 Travis-CI: <a href='https://travis-ci.org/akarnokd/async-enumerable-dotnet/builds'><img src='https://travis-ci.org/akarnokd/async-enumerable-dotnet.svg?branch=master' alt="async-enumerable-dotnet"></a>
 NuGet: <a href='https://www.nuget.org/packages/akarnokd.async-enumerable-dotnet'><img src='https://img.shields.io/nuget/v/akarnokd.async-enumerable-dotnet.svg' alt="async-enumerable-dotnet"/></a>
@@ -11,7 +11,12 @@ Namespace: `async_enumerable_dotnet`
 
 Factory/Extension methods: `AsyncEnumerable`
 
+Requires: .NET Core 3 or later
+
 ```cs
+using async_enumerable_dotnet;
+using System.Collections.Generic;
+
 var result = AsyncEnumerable.Range(1, 10)
     .Filter(v => v % 2 == 0)
     .Map(v => v * 2)

async-enumerable-dotnet-benchmark/Program.cs

@@ -4,6 +4,7 @@
 
 using async_enumerable_dotnet;
 using System;
+using System.Collections.Generic;
 
 namespace async_enumerable_dotnet_benchmark
 {

async-enumerable-dotnet-test/AsyncEnumerableTest.cs

@@ -190,18 +190,18 @@ static AsyncEnumerableTest()
             Defaults.Add(typeof(long), 1L);
 
             Defaults.Add(typeof(IEnumerable<int>), Enumerable.Empty<int>());
-            Defaults.Add(typeof(async_enumerable_dotnet.IAsyncEnumerable<int>), AsyncEnumerable.Empty<int>());
-            Defaults.Add(typeof(async_enumerable_dotnet.IAsyncEnumerable<int>[]), new[] { AsyncEnumerable.Empty<int>() });
+            Defaults.Add(typeof(IAsyncEnumerable<int>), AsyncEnumerable.Empty<int>());
+            Defaults.Add(typeof(IAsyncEnumerable<int>[]), new[] { AsyncEnumerable.Empty<int>() });
 
             Defaults.Add(typeof(Func<int>), (Func<int>)(() => 1));
             Defaults.Add(typeof(Func<int, bool>), (Func<int, bool>)(v => true));
             Defaults.Add(typeof(Func<int, int>), (Func<int, int>)(v => v));
             Defaults.Add(typeof(Func<int, int, int>), (Func<int, int, int>)((v, w) => v));
             Defaults.Add(typeof(Func<int[], int>), (Func<int[], int>)(v => v[0]));
-            Defaults.Add(typeof(Func<async_enumerable_dotnet.IAsyncEnumerable<int>>), (Func<async_enumerable_dotnet.IAsyncEnumerable<int>>)AsyncEnumerable.Empty<int>);
+            Defaults.Add(typeof(Func<IAsyncEnumerable<int>>), (Func<IAsyncEnumerable<int>>)AsyncEnumerable.Empty<int>);
             Defaults.Add(typeof(Func<int, IEnumerable<int>>), (Func<int, IEnumerable<int>>)(v => Enumerable.Empty<int>()));
-            Defaults.Add(typeof(Func<int, async_enumerable_dotnet.IAsyncEnumerable<int>>), (Func<int, async_enumerable_dotnet.IAsyncEnumerable<int>>)(v => AsyncEnumerable.Empty<int>()));
-            Defaults.Add(typeof(Func<Exception, async_enumerable_dotnet.IAsyncEnumerable<int>>), (Func<Exception, async_enumerable_dotnet.IAsyncEnumerable<int>>)(v => AsyncEnumerable.Empty<int>()));
+            Defaults.Add(typeof(Func<int, IAsyncEnumerable<int>>), (Func<int, IAsyncEnumerable<int>>)(v => AsyncEnumerable.Empty<int>()));
+            Defaults.Add(typeof(Func<Exception, IAsyncEnumerable<int>>), (Func<Exception, IAsyncEnumerable<int>>)(v => AsyncEnumerable.Empty<int>()));
             Defaults.Add(typeof(Func<int, Task>), (Func<int, Task>)(v => null));
             Defaults.Add(typeof(Func<int, Task<int>>), (Func<int, Task<int>>)(v => null));
             Defaults.Add(typeof(Func<int, Task<bool>>), (Func<int, Task<bool>>)(v => null));
@@ -214,7 +214,7 @@ static AsyncEnumerableTest()
             Defaults.Add(typeof(Func<long, Task<bool>>), (Func<long, Task<bool>>)(v => Task.FromResult(false)));
             Defaults.Add(typeof(Func<ISet<int>>), (Func<ISet<int>>)(() => null));
 
-            Defaults.Add(typeof(Func<async_enumerable_dotnet.IAsyncEnumerable<int>, async_enumerable_dotnet.IAsyncEnumerable<int>>), (Func<async_enumerable_dotnet.IAsyncEnumerable<int>, async_enumerable_dotnet.IAsyncEnumerable<int>>)(w => w));
+            Defaults.Add(typeof(Func<IAsyncEnumerable<int>, IAsyncEnumerable<int>>), (Func<IAsyncEnumerable<int>, IAsyncEnumerable<int>>)(w => w));
 
             Defaults.Add(typeof(Action), (Action)(() => { }));
             Defaults.Add(typeof(Action<int>), (Action<int>)(v => { }));

async-enumerable-dotnet-test/ConcatTest.cs

@@ -28,7 +28,7 @@ await AsyncEnumerable.Concat(
         [Fact]
         public async void Enumerable_Normal()
         {
-            await AsyncEnumerable.Concat((IEnumerable<async_enumerable_dotnet.IAsyncEnumerable<int>>)new[] {
+            await AsyncEnumerable.Concat((IEnumerable<IAsyncEnumerable<int>>)new[] {
                         AsyncEnumerable.Range(1, 3),
                         AsyncEnumerable.Empty<int>(),
                         AsyncEnumerable.FromArray(4, 5, 6, 7),

async-enumerable-dotnet-test/TestHelper.cs

@@ -16,7 +16,7 @@ namespace async_enumerable_dotnet_test
 {
     internal static class TestHelper
     {
-        public static ValueTask AssertResult<T>(this async_enumerable_dotnet.IAsyncEnumerable<T> source, params T[] values)
+        public static ValueTask AssertResult<T>(this IAsyncEnumerable<T> source, params T[] values)
         {
             return AssertResult(source.GetAsyncEnumerator(default), values);
         }
@@ -68,18 +68,18 @@ public static async ValueTask AssertResult<T>(this IAsyncEnumerator<T> source, p
             }
         }
 
-        public static async ValueTask AssertThen<T>(this async_enumerable_dotnet.IAsyncEnumerable<T> source, Action<IList<T>> outcomeHandler)
+        public static async ValueTask AssertThen<T>(this IAsyncEnumerable<T> source, Action<IList<T>> outcomeHandler)
         {
             var list = await source.ToListAsync();
             outcomeHandler(list);
         }
 
-        public static ValueTask AssertResultSet<T>(this async_enumerable_dotnet.IAsyncEnumerable<T> source, params T[] values)
+        public static ValueTask AssertResultSet<T>(this IAsyncEnumerable<T> source, params T[] values)
         {
             return AssertResultSet(source, EqualityComparer<T>.Default, values);
         }
 
-        public static async ValueTask AssertResultSet<T>(this async_enumerable_dotnet.IAsyncEnumerable<T> source, IEqualityComparer<T> comparer, params T[] values)
+        public static async ValueTask AssertResultSet<T>(this IAsyncEnumerable<T> source, IEqualityComparer<T> comparer, params T[] values)
         {
             var set = new HashSet<T>(values, comparer);
             var en = source.GetAsyncEnumerator(default);
@@ -121,7 +121,7 @@ private static string AsString(object obj)
             return obj != null ? obj.ToString() : "null";
         }
 
-        public static ValueTask AssertFailure<T>(this async_enumerable_dotnet.IAsyncEnumerable<T> source, Type exception, params T[] values)
+        public static ValueTask AssertFailure<T>(this IAsyncEnumerable<T> source, Type exception, params T[] values)
         {
             return AssertFailure(source.GetAsyncEnumerator(default), exception, values);
         }
@@ -164,7 +164,7 @@ public static async ValueTask AssertFailure<T>(this IAsyncEnumerator<T> source,
         /// </summary>
         /// <param name="timestamps">The params array of timestamps.</param>
         /// <returns>The new IAsyncEnumerable sequence.</returns>
-        internal static async_enumerable_dotnet.IAsyncEnumerable<long> TimeSequence(params long[] timestamps)
+        internal static IAsyncEnumerable<long> TimeSequence(params long[] timestamps)
         {
             return AsyncEnumerable.FromArray(timestamps)
                 .FlatMap(v => AsyncEnumerable.Timer(TimeSpan.FromMilliseconds(v)).Map(w => v));
@@ -177,7 +177,7 @@ internal static async_enumerable_dotnet.IAsyncEnumerable<long> TimeSequence(para
         /// <param name="error">Th error to append</param>
         /// <typeparam name="TSource">The element type of the sequence</typeparam>
         /// <returns>The new IAsyncEnumerable instance.</returns>
-        internal static async_enumerable_dotnet.IAsyncEnumerable<TSource> WithError<TSource>(this async_enumerable_dotnet.IAsyncEnumerable<TSource> source, Exception error)
+        internal static IAsyncEnumerable<TSource> WithError<TSource>(this IAsyncEnumerable<TSource> source, Exception error)
         {
             return source.ConcatWith(AsyncEnumerable.Error<TSource>(error));
         }

async-enumerable-dotnet/AsyncEnumerableAPI.cs

@@ -2,14 +2,16 @@
 // Licensed under the Apache 2.0 License.
 // See LICENSE file in the project root for full license information.
 
+using System.Collections.Generic;
+
 namespace async_enumerable_dotnet
 {
     /// <summary>
     /// An IAsyncEnumerable with a key property to support grouping operations.
     /// </summary>
     /// <typeparam name="TKey">The key type.</typeparam>
     /// <typeparam name="TValue">The element type of the async sequence.</typeparam>
-    public interface IAsyncGroupedEnumerable<out TKey, out TValue> : IAsyncEnumerable<TValue>
+    public interface IAsyncGroupedEnumerable<out TKey, TValue> : IAsyncEnumerable<TValue>
     {
         /// <summary>
         /// Returns the group key.

async-enumerable-dotnet/IAsyncGroupedEnumerable.cs

@@ -5,6 +5,7 @@
 using System;
 using System.Runtime.CompilerServices;
 using System.Threading.Tasks;
+using System.Collections.Generic;
 
 namespace async_enumerable_dotnet.impl
 {

async-enumerable-dotnet/impl/FirstLastSingleAsync.cs

@@ -6,6 +6,7 @@
 using System.Runtime.CompilerServices;
 using System.Threading;
 using System.Threading.Tasks;
+using System.Collections.Generic;
 
 namespace async_enumerable_dotnet.impl
 {