Rename MoveNext to MoveNextAsync.

Ix.NET/Source/System.Interactive.Async/Aggregate.cs

@@ -83,7 +83,7 @@ namespace System.Linq
 
             using (var e = source.GetAsyncEnumerator())
             {
-                while (await e.MoveNext(cancellationToken)
+                while (await e.MoveNextAsync(cancellationToken)
                               .ConfigureAwait(false))
                 {
                     acc = accumulator(acc, e.Current);
@@ -100,7 +100,7 @@ namespace System.Linq
 
             using (var e = source.GetAsyncEnumerator())
             {
-                while (await e.MoveNext(cancellationToken)
+                while (await e.MoveNextAsync(cancellationToken)
                               .ConfigureAwait(false))
                 {
                     acc = first ? e.Current : accumulator(acc, e.Current);

Ix.NET/Source/System.Interactive.Async/AnyAll.cs

@@ -67,7 +67,7 @@ namespace System.Linq
 
             using (var e = source.GetAsyncEnumerator())
             {
-                return await e.MoveNext(cancellationToken).ConfigureAwait(false);
+                return await e.MoveNextAsync(cancellationToken).ConfigureAwait(false);
             }
         }
 
@@ -75,7 +75,7 @@ namespace System.Linq
         {
             using (var e = source.GetAsyncEnumerator())
             {
-                while (await e.MoveNext(cancellationToken)
+                while (await e.MoveNextAsync(cancellationToken)
                               .ConfigureAwait(false))
                 {
                     if (!predicate(e.Current))
@@ -89,7 +89,7 @@ namespace System.Linq
         {
             using (var e = source.GetAsyncEnumerator())
             {
-                while (await e.MoveNext(cancellationToken)
+                while (await e.MoveNextAsync(cancellationToken)
                               .ConfigureAwait(false))
                 {
                     if (predicate(e.Current))

Ix.NET/Source/System.Interactive.Async/AppendPrepend.cs

@@ -62,7 +62,7 @@ namespace System.Linq
 
             protected async Task<bool> LoadFromEnumerator(CancellationToken cancellationToken)
             {
-                if (await enumerator.MoveNext(cancellationToken)
+                if (await enumerator.MoveNextAsync(cancellationToken)
                                     .ConfigureAwait(false))
                 {
                     current = enumerator.Current;
@@ -203,7 +203,7 @@ namespace System.Linq
                 {
                     using (var en = source.GetAsyncEnumerator())
                     {
-                        while (await en.MoveNext(cancellationToken)
+                        while (await en.MoveNextAsync(cancellationToken)
                                        .ConfigureAwait(false))
                         {
                             array[index] = en.Current;
@@ -233,7 +233,7 @@ namespace System.Linq
 
                 using (var en = source.GetAsyncEnumerator())
                 {
-                    while (await en.MoveNext(cancellationToken)
+                    while (await en.MoveNextAsync(cancellationToken)
                                    .ConfigureAwait(false))
                     {
                         list.Add(en.Current);
@@ -437,7 +437,7 @@ namespace System.Linq
                 {
                     using (var en = source.GetAsyncEnumerator())
                     {
-                        while (await en.MoveNext(cancellationToken)
+                        while (await en.MoveNextAsync(cancellationToken)
                                        .ConfigureAwait(false))
                         {
                             array[index] = en.Current;
@@ -467,7 +467,7 @@ namespace System.Linq
 
                 using (var en = source.GetAsyncEnumerator())
                 {
-                    while (await en.MoveNext(cancellationToken)
+                    while (await en.MoveNextAsync(cancellationToken)
                                    .ConfigureAwait(false))
                     {
                         list.Add(en.Current);

Ix.NET/Source/System.Interactive.Async/AsyncEnumerableHelpers.cs

@@ -45,7 +45,7 @@ namespace System.Collections.Generic
             {
                 using (var en = source.GetAsyncEnumerator())
                 {
-                    if (await en.MoveNext(cancellationToken)
+                    if (await en.MoveNextAsync(cancellationToken)
                                 .ConfigureAwait(false))
                     {
                         const int DefaultCapacity = 4;
@@ -53,7 +53,7 @@ namespace System.Collections.Generic
                         arr[0] = en.Current;
                         var count = 1;
 
-                        while (await en.MoveNext(cancellationToken)
+                        while (await en.MoveNextAsync(cancellationToken)
                                        .ConfigureAwait(false))
                         {
                             if (count == arr.Length)

Ix.NET/Source/System.Interactive.Async/AsyncEnumerator.cs

@@ -22,7 +22,7 @@ namespace System.Collections.Generic
             if (enumerator == null)
                 throw new ArgumentNullException(nameof(enumerator));
 
-            return enumerator.MoveNext(CancellationToken.None);
+            return enumerator.MoveNextAsync(CancellationToken.None);
         }
     }
 }

Ix.NET/Source/System.Interactive.Async/AsyncIterator.cs

@@ -73,7 +73,7 @@ namespace System.Linq
                 }
             }
 
-            public async Task<bool> MoveNext(CancellationToken cancellationToken)
+            public async Task<bool> MoveNextAsync(CancellationToken cancellationToken)
             {
                 // Note: MoveNext *must* be implemented as an async method to ensure
                 // that any exceptions thrown from the MoveNextCore call are handled 

Ix.NET/Source/System.Interactive.Async/Average.cs

@@ -385,7 +385,7 @@ namespace System.Linq
         {
             using (var e = source.GetAsyncEnumerator())
             {
-                if (!await e.MoveNext(cancellationToken)
+                if (!await e.MoveNextAsync(cancellationToken)
                             .ConfigureAwait(false))
                 {
                     throw new InvalidOperationException(Strings.NO_ELEMENTS);
@@ -395,7 +395,7 @@ namespace System.Linq
                 long count = 1;
                 checked
                 {
-                    while (await e.MoveNext(cancellationToken)
+                    while (await e.MoveNextAsync(cancellationToken)
                                   .ConfigureAwait(false))
                     {
                         sum += e.Current;
@@ -411,7 +411,7 @@ namespace System.Linq
         {
             using (var e = source.GetAsyncEnumerator())
             {
-                while (await e.MoveNext(cancellationToken)
+                while (await e.MoveNextAsync(cancellationToken)
                               .ConfigureAwait(false))
                 {
                     var v = e.Current;
@@ -421,7 +421,7 @@ namespace System.Linq
                         long count = 1;
                         checked
                         {
-                            while (await e.MoveNext(cancellationToken)
+                            while (await e.MoveNextAsync(cancellationToken)
                                           .ConfigureAwait(false))
                             {
                                 v = e.Current;
@@ -445,7 +445,7 @@ namespace System.Linq
         {
             using (var e = source.GetAsyncEnumerator())
             {
-                if (!await e.MoveNext(cancellationToken)
+                if (!await e.MoveNextAsync(cancellationToken)
                             .ConfigureAwait(false))
                 {
                     throw new InvalidOperationException(Strings.NO_ELEMENTS);
@@ -455,7 +455,7 @@ namespace System.Linq
                 long count = 1;
                 checked
                 {
-                    while (await e.MoveNext(cancellationToken)
+                    while (await e.MoveNextAsync(cancellationToken)
                                   .ConfigureAwait(false))
                     {
                         sum += e.Current;
@@ -471,7 +471,7 @@ namespace System.Linq
         {
             using (var e = source.GetAsyncEnumerator())
             {
-                while (await e.MoveNext(cancellationToken)
+                while (await e.MoveNextAsync(cancellationToken)
                               .ConfigureAwait(false))
                 {
                     var v = e.Current;
@@ -481,7 +481,7 @@ namespace System.Linq
                         long count = 1;
                         checked
                         {
-                            while (await e.MoveNext(cancellationToken)
+                            while (await e.MoveNextAsync(cancellationToken)
                                           .ConfigureAwait(false))
                             {
                                 v = e.Current;
@@ -505,7 +505,7 @@ namespace System.Linq
         {
             using (var e = source.GetAsyncEnumerator())
             {
-                if (!await e.MoveNext(cancellationToken)
+                if (!await e.MoveNextAsync(cancellationToken)
                             .ConfigureAwait(false))
                 {
                     throw new InvalidOperationException(Strings.NO_ELEMENTS);
@@ -513,7 +513,7 @@ namespace System.Linq
 
                 var sum = e.Current;
                 long count = 1;
-                while (await e.MoveNext(cancellationToken)
+                while (await e.MoveNextAsync(cancellationToken)
                               .ConfigureAwait(false))
                 {
                     // There is an opportunity to short-circuit here, in that if e.Current is
@@ -531,7 +531,7 @@ namespace System.Linq
         {
             using (var e = source.GetAsyncEnumerator())
             {
-                while (await e.MoveNext(cancellationToken)
+                while (await e.MoveNextAsync(cancellationToken)
                               .ConfigureAwait(false))
                 {
                     var v = e.Current;
@@ -541,7 +541,7 @@ namespace System.Linq
                         long count = 1;
                         checked
                         {
-                            while (await e.MoveNext(cancellationToken)
+                            while (await e.MoveNextAsync(cancellationToken)
                                           .ConfigureAwait(false))
                             {
                                 v = e.Current;
@@ -565,7 +565,7 @@ namespace System.Linq
         {
             using (var e = source.GetAsyncEnumerator())
             {
-                if (!await e.MoveNext(cancellationToken)
+                if (!await e.MoveNextAsync(cancellationToken)
                             .ConfigureAwait(false))
                 {
                     throw new InvalidOperationException(Strings.NO_ELEMENTS);
@@ -573,7 +573,7 @@ namespace System.Linq
 
                 double sum = e.Current;
                 long count = 1;
-                while (await e.MoveNext(cancellationToken)
+                while (await e.MoveNextAsync(cancellationToken)
                               .ConfigureAwait(false))
                 {
                     sum += e.Current;
@@ -588,7 +588,7 @@ namespace System.Linq
         {
             using (var e = source.GetAsyncEnumerator())
             {
-                while (await e.MoveNext(cancellationToken)
+                while (await e.MoveNextAsync(cancellationToken)
                               .ConfigureAwait(false))
                 {
                     var v = e.Current;
@@ -598,7 +598,7 @@ namespace System.Linq
                         long count = 1;
                         checked
                         {
-                            while (await e.MoveNext(cancellationToken)
+                            while (await e.MoveNextAsync(cancellationToken)
                                           .ConfigureAwait(false))
                             {
                                 v = e.Current;
@@ -622,7 +622,7 @@ namespace System.Linq
         {
             using (var e = source.GetAsyncEnumerator())
             {
-                if (!await e.MoveNext(cancellationToken)
+                if (!await e.MoveNextAsync(cancellationToken)
                             .ConfigureAwait(false))
                 {
                     throw new InvalidOperationException(Strings.NO_ELEMENTS);
@@ -630,7 +630,7 @@ namespace System.Linq
 
                 var sum = e.Current;
                 long count = 1;
-                while (await e.MoveNext(cancellationToken)
+                while (await e.MoveNextAsync(cancellationToken)
                               .ConfigureAwait(false))
                 {
                     sum += e.Current;
@@ -645,7 +645,7 @@ namespace System.Linq
         {
             using (var e = source.GetAsyncEnumerator())
             {
-                while (await e.MoveNext(cancellationToken)
+                while (await e.MoveNextAsync(cancellationToken)
                               .ConfigureAwait(false))
                 {
                     var v = e.Current;
@@ -653,7 +653,7 @@ namespace System.Linq
                     {
                         var sum = v.GetValueOrDefault();
                         long count = 1;
-                        while (await e.MoveNext(cancellationToken)
+                        while (await e.MoveNextAsync(cancellationToken)
                                       .ConfigureAwait(false))
                         {
                             v = e.Current;

Ix.NET/Source/System.Interactive.Async/Buffer.cs

@@ -89,7 +89,7 @@ namespace System.Linq
                         {
                             if (!stopped)
                             {
-                                if (await enumerator.MoveNext(cancellationToken)
+                                if (await enumerator.MoveNextAsync(cancellationToken)
                                                     .ConfigureAwait(false))
                                 {
                                     var item = enumerator.Current;

Ix.NET/Source/System.Interactive.Async/Catch.cs

@@ -105,7 +105,7 @@ namespace System.Linq
                             {
                                 try
                                 {
-                                    if (await enumerator.MoveNext(cancellationToken)
+                                    if (await enumerator.MoveNextAsync(cancellationToken)
                                                         .ConfigureAwait(false))
                                     {
                                         current = enumerator.Current;
@@ -126,7 +126,7 @@ namespace System.Linq
                                 }
                             }
 
-                            if (await enumerator.MoveNext(cancellationToken)
+                            if (await enumerator.MoveNextAsync(cancellationToken)
                                                 .ConfigureAwait(false))
                             {
                                 current = enumerator.Current;
@@ -212,7 +212,7 @@ namespace System.Linq
 
                             try
                             {
-                                if (await enumerator.MoveNext(cancellationToken)
+                                if (await enumerator.MoveNextAsync(cancellationToken)
                                                     .ConfigureAwait(false))
                                 {
                                     current = enumerator.Current;

Ix.NET/Source/System.Interactive.Async/Concatenate.cs

@@ -113,7 +113,7 @@ namespace System.Linq
 
                                 break;
                             case State_While:
-                                if (await currentEnumerator.MoveNext(cancellationToken)
+                                if (await currentEnumerator.MoveNextAsync(cancellationToken)
                                                            .ConfigureAwait(false))
                                 {
                                     current = currentEnumerator.Current;
@@ -193,7 +193,7 @@ namespace System.Linq
                     }
                     using (var e = source.GetAsyncEnumerator())
                     {
-                        while (await e.MoveNext(cancellationToken)
+                        while (await e.MoveNextAsync(cancellationToken)
                                       .ConfigureAwait(false))
                         {
                             list.Add(e.Current);
@@ -254,7 +254,7 @@ namespace System.Linq
                 {
                     while (true)
                     {
-                        if (await enumerator.MoveNext(cancellationToken)
+                        if (await enumerator.MoveNextAsync(cancellationToken)
                                             .ConfigureAwait(false))
                         {
                             current = enumerator.Current;

Ix.NET/Source/System.Interactive.Async/DefaultIfEmpty.cs

@@ -65,7 +65,7 @@ namespace System.Linq
                 {
                     case AsyncIteratorState.Allocated:
                         enumerator = source.GetAsyncEnumerator();
-                        if (await enumerator.MoveNext(cancellationToken)
+                        if (await enumerator.MoveNextAsync(cancellationToken)
                                             .ConfigureAwait(false))
                         {
                             current = enumerator.Current;
@@ -82,7 +82,7 @@ namespace System.Linq
                         return true;
 
                     case AsyncIteratorState.Iterating:
-                        if (await enumerator.MoveNext(cancellationToken)
+                        if (await enumerator.MoveNextAsync(cancellationToken)
                                             .ConfigureAwait(false))
                         {
                             current = enumerator.Current;

Ix.NET/Source/System.Interactive.Async/Distinct.cs

@@ -141,7 +141,7 @@ namespace System.Linq
                 var s = new Set<TKey>(comparer);
                 using (var enu = source.GetAsyncEnumerator())
                 {
-                    while (await enu.MoveNext(cancellationToken)
+                    while (await enu.MoveNextAsync(cancellationToken)
                                     .ConfigureAwait(false))
                     {
                         var item = enu.Current;
@@ -178,7 +178,7 @@ namespace System.Linq
                 {
                     case AsyncIteratorState.Allocated:
                         enumerator = source.GetAsyncEnumerator();
-                        if (!await enumerator.MoveNext(cancellationToken)
+                        if (!await enumerator.MoveNextAsync(cancellationToken)
                                              .ConfigureAwait(false))
                         {
                             Dispose();
@@ -193,7 +193,7 @@ namespace System.Linq
                         return true;
 
                     case AsyncIteratorState.Iterating:
-                        while (await enumerator.MoveNext(cancellationToken)
+                        while (await enumerator.MoveNextAsync(cancellationToken)
                                                .ConfigureAwait(false))
                         {
                             element = enumerator.Current;
@@ -217,7 +217,7 @@ namespace System.Linq
                 var r = new List<TSource>();
                 using (var enu = source.GetAsyncEnumerator())
                 {
-                    while (await enu.MoveNext(cancellationToken)
+                    while (await enu.MoveNextAsync(cancellationToken)
                                     .ConfigureAwait(false))
                     {
                         var item = enu.Current;
@@ -291,7 +291,7 @@ namespace System.Linq
                 {
                     case AsyncIteratorState.Allocated:
                         enumerator = source.GetAsyncEnumerator();
-                        if (!await enumerator.MoveNext(cancellationToken)
+                        if (!await enumerator.MoveNextAsync(cancellationToken)
                                              .ConfigureAwait(false))
                         {
                             Dispose();
@@ -306,7 +306,7 @@ namespace System.Linq
                         return true;
 
                     case AsyncIteratorState.Iterating:
-                        while (await enumerator.MoveNext(cancellationToken)
+                        while (await enumerator.MoveNextAsync(cancellationToken)
                                                .ConfigureAwait(false))
                         {
                             element = enumerator.Current;
@@ -329,7 +329,7 @@ namespace System.Linq
                 var s = new Set<TSource>(comparer);
                 using (var enu = source.GetAsyncEnumerator())
                 {
-                    while (await enu.MoveNext(cancellationToken)
+                    while (await enu.MoveNextAsync(cancellationToken)
                                     .ConfigureAwait(false))
                     {
                         s.Add(enu.Current);
@@ -385,7 +385,7 @@ namespace System.Linq
                         goto case AsyncIteratorState.Iterating;
 
                     case AsyncIteratorState.Iterating:
-                        while (await enumerator.MoveNext(cancellationToken)
+                        while (await enumerator.MoveNextAsync(cancellationToken)
                                             .ConfigureAwait(false))
                         {
                             var item = enumerator.Current;
@@ -456,7 +456,7 @@ namespace System.Linq
                         goto case AsyncIteratorState.Iterating;
 
                     case AsyncIteratorState.Iterating:
-                        while (await enumerator.MoveNext(cancellationToken)
+                        while (await enumerator.MoveNextAsync(cancellationToken)
                                                .ConfigureAwait(false))
                         {
                             var item = enumerator.Current;

Ix.NET/Source/System.Interactive.Async/Do.cs

@@ -122,7 +122,7 @@ namespace System.Linq
                     case AsyncIteratorState.Iterating:
                         try
                         {
-                            if (await enumerator.MoveNext(cancellationToken)
+                            if (await enumerator.MoveNextAsync(cancellationToken)
                                                 .ConfigureAwait(false))
                             {
                                 current = enumerator.Current;

Ix.NET/Source/System.Interactive.Async/ElementAt.cs

@@ -60,7 +60,7 @@ namespace System.Linq
             {
                 using (var e = source.GetAsyncEnumerator())
                 {
-                    while (await e.MoveNext(cancellationToken)
+                    while (await e.MoveNextAsync(cancellationToken)
                                   .ConfigureAwait(false))
                     {
                         if (index == 0)
@@ -82,7 +82,7 @@ namespace System.Linq
             {
                 using (var e = source.GetAsyncEnumerator())
                 {
-                    while (await e.MoveNext(cancellationToken)
+                    while (await e.MoveNextAsync(cancellationToken)
                                   .ConfigureAwait(false))
                     {
                         if (index == 0)

Ix.NET/Source/System.Interactive.Async/Except.cs

@@ -95,7 +95,7 @@ namespace System.Linq
                             if (!setFilled)
                             {
                                 // This is here so we don't need to call Task.WhenAll each time after the set is filled
-                                var moveNextTask = firstEnumerator.MoveNext(cancellationToken);
+                                var moveNextTask = firstEnumerator.MoveNextAsync(cancellationToken);
                                 await Task.WhenAll(moveNextTask, fillSetTask)
                                           .ConfigureAwait(false);
                                 setFilled = true;
@@ -103,7 +103,7 @@ namespace System.Linq
                             }
                             else
                             {
-                                moveNext = await firstEnumerator.MoveNext(cancellationToken)
+                                moveNext = await firstEnumerator.MoveNextAsync(cancellationToken)
                                                                 .ConfigureAwait(false);
                             }
 

Ix.NET/Source/System.Interactive.Async/Expand.cs

@@ -86,7 +86,7 @@ namespace System.Linq
                                 break; // while
                             }
 
-                            if (await enumerator.MoveNext(cancellationToken)
+                            if (await enumerator.MoveNextAsync(cancellationToken)
                                                 .ConfigureAwait(false))
                             {
                                 var item = enumerator.Current;

Ix.NET/Source/System.Interactive.Async/Finally.cs

@@ -65,7 +65,7 @@ namespace System.Linq
                         goto case AsyncIteratorState.Iterating;
 
                     case AsyncIteratorState.Iterating:
-                        if (await enumerator.MoveNext(cancellationToken)
+                        if (await enumerator.MoveNextAsync(cancellationToken)
                                             .ConfigureAwait(false))
                         {
                             current = enumerator.Current;

Ix.NET/Source/System.Interactive.Async/First.cs

@@ -96,7 +96,7 @@ namespace System.Linq
 
             using (var e = source.GetAsyncEnumerator())
             {
-                if (await e.MoveNext(cancellationToken)
+                if (await e.MoveNextAsync(cancellationToken)
                            .ConfigureAwait(false))
                 {
                     return e.Current;
@@ -115,7 +115,7 @@ namespace System.Linq
 
             using (var e = source.GetAsyncEnumerator())
             {
-                if (await e.MoveNext(cancellationToken)
+                if (await e.MoveNextAsync(cancellationToken)
                            .ConfigureAwait(false))
                 {
                     return e.Current;

Ix.NET/Source/System.Interactive.Async/ForEach.cs

@@ -100,7 +100,7 @@ namespace System.Linq
             var index = 0;
             using (var e = source.GetAsyncEnumerator())
             {
-                while (await e.MoveNext(cancellationToken)
+                while (await e.MoveNextAsync(cancellationToken)
                               .ConfigureAwait(false))
                 {
                     action(e.Current, checked(index++));

Ix.NET/Source/System.Interactive.Async/GroupJoin.cs

@@ -111,10 +111,10 @@ namespace System.Linq
                     _comparer = comparer;
                 }
 
-                public async Task<bool> MoveNext(CancellationToken cancellationToken)
+                public async Task<bool> MoveNextAsync(CancellationToken cancellationToken)
                 {
                     // nothing to do 
-                    if (!await _outer.MoveNext(cancellationToken)
+                    if (!await _outer.MoveNextAsync(cancellationToken)
                                      .ConfigureAwait(false))
                     {
                         return false;

Ix.NET/Source/System.Interactive.Async/IAsyncEnumerator.cs

@@ -27,6 +27,6 @@ namespace System.Collections.Generic
         ///     Task containing the result of the operation: true if the enumerator was successfully advanced
         ///     to the next element; false if the enumerator has passed the end of the sequence.
         /// </returns>
-        Task<bool> MoveNext(CancellationToken cancellationToken);
+        Task<bool> MoveNextAsync(CancellationToken cancellationToken);
     }
 }

Ix.NET/Source/System.Interactive.Async/IgnoreElements.cs

@@ -57,7 +57,7 @@ namespace System.Linq
                         goto case AsyncIteratorState.Iterating;
 
                     case AsyncIteratorState.Iterating:
-                        while (await enumerator.MoveNext(cancellationToken)
+                        while (await enumerator.MoveNextAsync(cancellationToken)
                                                .ConfigureAwait(false))
                         {
                             // Do nothing, we're ignoring these elements

Ix.NET/Source/System.Interactive.Async/Intersect.cs

@@ -97,7 +97,7 @@ namespace System.Linq
                             if (!setFilled)
                             {
                                 // This is here so we don't need to call Task.WhenAll each time after the set is filled
-                                var moveNextTask = firstEnumerator.MoveNext(cancellationToken);
+                                var moveNextTask = firstEnumerator.MoveNextAsync(cancellationToken);
                                 await Task.WhenAll(moveNextTask, fillSetTask)
                                           .ConfigureAwait(false);
                                 setFilled = true;
@@ -105,7 +105,7 @@ namespace System.Linq
                             }
                             else
                             {
-                                moveNext = await firstEnumerator.MoveNext(cancellationToken)
+                                moveNext = await firstEnumerator.MoveNextAsync(cancellationToken)
                                                                 .ConfigureAwait(false);
                             }
 

Ix.NET/Source/System.Interactive.Async/Join.cs

@@ -116,7 +116,7 @@ namespace System.Linq
                         switch (mode)
                         {
                             case State_If:
-                                if (await outerEnumerator.MoveNext(cancellationToken)
+                                if (await outerEnumerator.MoveNextAsync(cancellationToken)
                                                          .ConfigureAwait(false))
                                 {
                                     lookup = await Internal.Lookup<TKey, TInner>.CreateForJoinAsync(inner, innerKeySelector, comparer, cancellationToken).ConfigureAwait(false);
@@ -155,7 +155,7 @@ namespace System.Linq
                                 return true;
 
                             case State_While:
-                                var hasNext = await outerEnumerator.MoveNext(cancellationToken).ConfigureAwait(false);
+                                var hasNext = await outerEnumerator.MoveNextAsync(cancellationToken).ConfigureAwait(false);
                                 if (hasNext)
                                 {
                                     goto case State_DoLoop;

Ix.NET/Source/System.Interactive.Async/Last.cs

@@ -102,7 +102,7 @@ namespace System.Linq
 
             using (var e = source.GetAsyncEnumerator())
             {
-                while (await e.MoveNext(cancellationToken)
+                while (await e.MoveNextAsync(cancellationToken)
                               .ConfigureAwait(false))
                 {
                     hasLast = true;
@@ -130,7 +130,7 @@ namespace System.Linq
 
             using (var e = source.GetAsyncEnumerator())
             {
-                while (await e.MoveNext(cancellationToken)
+                while (await e.MoveNextAsync(cancellationToken)
                               .ConfigureAwait(false))
                 {
                     hasLast = true;

Ix.NET/Source/System.Interactive.Async/Lookup.cs

@@ -198,7 +198,7 @@ namespace System.Linq.Internal
             var lookup = new Lookup<TKey, TElement>(comparer);
             using (var enu = source.GetAsyncEnumerator())
             {
-                while (await enu.MoveNext(cancellationToken)
+                while (await enu.MoveNextAsync(cancellationToken)
                                 .ConfigureAwait(false))
                 {
                     lookup.GetGrouping(keySelector(enu.Current), create: true)
@@ -217,7 +217,7 @@ namespace System.Linq.Internal
             var lookup = new Lookup<TKey, TElement>(comparer);
             using (var enu = source.GetAsyncEnumerator())
             {
-                while (await enu.MoveNext(cancellationToken)
+                while (await enu.MoveNextAsync(cancellationToken)
                                 .ConfigureAwait(false))
                 {
                     lookup.GetGrouping(keySelector(enu.Current), create: true)
@@ -233,7 +233,7 @@ namespace System.Linq.Internal
             var lookup = new Lookup<TKey, TElement>(comparer);
             using (var enu = source.GetAsyncEnumerator())
             {
-                while (await enu.MoveNext(cancellationToken)
+                while (await enu.MoveNextAsync(cancellationToken)
                                 .ConfigureAwait(false))
                 {
                     var key = keySelector(enu.Current);

Ix.NET/Source/System.Interactive.Async/Min.cs

@@ -495,7 +495,7 @@ namespace System.Linq
 
             using (var e = source.GetAsyncEnumerator())
             {
-                if (!await e.MoveNext(cancellationToken)
+                if (!await e.MoveNextAsync(cancellationToken)
                             .ConfigureAwait(false))
                     throw new InvalidOperationException(Strings.NO_ELEMENTS);
 
@@ -503,7 +503,7 @@ namespace System.Linq
                 var resKey = keySelector(current);
                 result.Add(current);
 
-                while (await e.MoveNext(cancellationToken)
+                while (await e.MoveNextAsync(cancellationToken)
                               .ConfigureAwait(false))
                 {
                     var cur = e.Current;

Ix.NET/Source/System.Interactive.Async/OnErrorResumeNext.cs

@@ -105,7 +105,7 @@ namespace System.Linq
 
                             try
                             {
-                                if (await enumerator.MoveNext(cancellationToken)
+                                if (await enumerator.MoveNextAsync(cancellationToken)
                                                     .ConfigureAwait(false))
                                 {
                                     current = enumerator.Current;

Ix.NET/Source/System.Interactive.Async/Repeat.cs

@@ -119,7 +119,7 @@ namespace System.Linq
                         goto case AsyncIteratorState.Iterating;
 
                     case AsyncIteratorState.Iterating:
-                        if (await enumerator.MoveNext(cancellationToken)
+                        if (await enumerator.MoveNextAsync(cancellationToken)
                                             .ConfigureAwait(false))
                         {
                             current = enumerator.Current;

Ix.NET/Source/System.Interactive.Async/Scan.cs

@@ -79,7 +79,7 @@ namespace System.Linq
                         goto case AsyncIteratorState.Iterating;
 
                     case AsyncIteratorState.Iterating:
-                        if (await enumerator.MoveNext(cancellationToken)
+                        if (await enumerator.MoveNextAsync(cancellationToken)
                                              .ConfigureAwait(false))
                         {
                             var item = enumerator.Current;
@@ -147,7 +147,7 @@ namespace System.Linq
 
                     case AsyncIteratorState.Iterating:
 
-                        while (await enumerator.MoveNext(cancellationToken)
+                        while (await enumerator.MoveNextAsync(cancellationToken)
                                                .ConfigureAwait(false))
                         {
                             var item = enumerator.Current;

Ix.NET/Source/System.Interactive.Async/Select.cs

@@ -93,7 +93,7 @@ namespace System.Linq
                         goto case AsyncIteratorState.Iterating;
 
                     case AsyncIteratorState.Iterating:
-                        if (await enumerator.MoveNext(cancellationToken)
+                        if (await enumerator.MoveNextAsync(cancellationToken)
                                             .ConfigureAwait(false))
                         {
                             current = selector(enumerator.Current);
@@ -151,7 +151,7 @@ namespace System.Linq
                         goto case AsyncIteratorState.Iterating;
 
                     case AsyncIteratorState.Iterating:
-                        if (await enumerator.MoveNext(cancellationToken)
+                        if (await enumerator.MoveNextAsync(cancellationToken)
                                             .ConfigureAwait(false))
                         {
                             checked

Ix.NET/Source/System.Interactive.Async/SelectMany.cs

@@ -123,7 +123,7 @@ namespace System.Linq
                         switch (mode)
                         {
                             case State_Source:
-                                if (await sourceEnumerator.MoveNext(cancellationToken)
+                                if (await sourceEnumerator.MoveNextAsync(cancellationToken)
                                                           .ConfigureAwait(false))
                                 {
                                     resultEnumerator?.Dispose();
@@ -136,7 +136,7 @@ namespace System.Linq
                                 break;
 
                             case State_Result:
-                                if (await resultEnumerator.MoveNext(cancellationToken)
+                                if (await resultEnumerator.MoveNextAsync(cancellationToken)
                                                           .ConfigureAwait(false))
                                 {
                                     current = resultEnumerator.Current;
@@ -218,7 +218,7 @@ namespace System.Linq
                         switch (mode)
                         {
                             case State_Source:
-                                if (await sourceEnumerator.MoveNext(cancellationToken)
+                                if (await sourceEnumerator.MoveNextAsync(cancellationToken)
                                                           .ConfigureAwait(false))
                                 {
                                     resultEnumerator?.Dispose();
@@ -232,7 +232,7 @@ namespace System.Linq
                                 break;
 
                             case State_Result:
-                                if (await resultEnumerator.MoveNext(cancellationToken)
+                                if (await resultEnumerator.MoveNextAsync(cancellationToken)
                                                           .ConfigureAwait(false))
                                 {
                                     current = resultSelector(currentSource, resultEnumerator.Current);
@@ -316,7 +316,7 @@ namespace System.Linq
                         switch (mode)
                         {
                             case State_Source:
-                                if (await sourceEnumerator.MoveNext(cancellationToken)
+                                if (await sourceEnumerator.MoveNextAsync(cancellationToken)
                                                           .ConfigureAwait(false))
                                 {
                                     resultEnumerator?.Dispose();
@@ -336,7 +336,7 @@ namespace System.Linq
                                 break;
 
                             case State_Result:
-                                if (await resultEnumerator.MoveNext(cancellationToken)
+                                if (await resultEnumerator.MoveNextAsync(cancellationToken)
                                                           .ConfigureAwait(false))
                                 {
                                     current = resultSelector(currentSource, resultEnumerator.Current);
@@ -414,7 +414,7 @@ namespace System.Linq
                         switch (mode)
                         {
                             case State_Source:
-                                if (await sourceEnumerator.MoveNext(cancellationToken)
+                                if (await sourceEnumerator.MoveNextAsync(cancellationToken)
                                                           .ConfigureAwait(false))
                                 {
                                     resultEnumerator?.Dispose();
@@ -431,7 +431,7 @@ namespace System.Linq
                                 break;
 
                             case State_Result:
-                                if (await resultEnumerator.MoveNext(cancellationToken)
+                                if (await resultEnumerator.MoveNextAsync(cancellationToken)
                                                           .ConfigureAwait(false))
                                 {
                                     current = resultEnumerator.Current;

Ix.NET/Source/System.Interactive.Async/SequenceEqual.cs

@@ -71,17 +71,17 @@ namespace System.Linq
             using (var e1 = first.GetAsyncEnumerator())
             using (var e2 = second.GetAsyncEnumerator())
             {
-                while (await e1.MoveNext(cancellationToken)
+                while (await e1.MoveNextAsync(cancellationToken)
                                .ConfigureAwait(false))
                 {
-                    if (!(await e2.MoveNext(cancellationToken)
+                    if (!(await e2.MoveNextAsync(cancellationToken)
                                   .ConfigureAwait(false) && comparer.Equals(e1.Current, e2.Current)))
                     {
                         return false;
                     }
                 }
 
-                return !await e2.MoveNext(cancellationToken)
+                return !await e2.MoveNextAsync(cancellationToken)
                                 .ConfigureAwait(false);
             }
         }

Ix.NET/Source/System.Interactive.Async/Single.cs

@@ -101,13 +101,13 @@ namespace System.Linq
 
             using (var e = source.GetAsyncEnumerator())
             {
-                if (!await e.MoveNext(cancellationToken)
+                if (!await e.MoveNextAsync(cancellationToken)
                             .ConfigureAwait(false))
                 {
                     throw new InvalidOperationException(Strings.NO_ELEMENTS);
                 }
                 var result = e.Current;
-                if (await e.MoveNext(cancellationToken)
+                if (await e.MoveNextAsync(cancellationToken)
                            .ConfigureAwait(false))
                 {
                     throw new InvalidOperationException(Strings.MORE_THAN_ONE_ELEMENT);
@@ -130,14 +130,14 @@ namespace System.Linq
 
             using (var e = source.GetAsyncEnumerator())
             {
-                if (!await e.MoveNext(cancellationToken)
+                if (!await e.MoveNextAsync(cancellationToken)
                             .ConfigureAwait(false))
                 {
                     return default(TSource);
                 }
 
                 var result = e.Current;
-                if (!await e.MoveNext(cancellationToken)
+                if (!await e.MoveNextAsync(cancellationToken)
                             .ConfigureAwait(false))
                 {
                     return result;

Ix.NET/Source/System.Interactive.Async/Skip.cs

@@ -113,7 +113,7 @@ namespace System.Linq
                         enumerator = source.GetAsyncEnumerator();
 
                         // skip elements as requested
-                        while (currentCount > 0 && await enumerator.MoveNext(cancellationToken)
+                        while (currentCount > 0 && await enumerator.MoveNextAsync(cancellationToken)
                                                                    .ConfigureAwait(false))
                         {
                             currentCount--;
@@ -126,7 +126,7 @@ namespace System.Linq
                         break;
 
                     case AsyncIteratorState.Iterating:
-                        if (await enumerator.MoveNext(cancellationToken)
+                        if (await enumerator.MoveNextAsync(cancellationToken)
                                             .ConfigureAwait(false))
                         {
                             current = enumerator.Current;
@@ -188,7 +188,7 @@ namespace System.Linq
 
 
                     case AsyncIteratorState.Iterating:
-                        while (await enumerator.MoveNext(cancellationToken)
+                        while (await enumerator.MoveNextAsync(cancellationToken)
                                             .ConfigureAwait(false))
                         {
                             var item = enumerator.Current;
@@ -249,7 +249,7 @@ namespace System.Linq
                         enumerator = source.GetAsyncEnumerator();
 
                         // skip elements as requested
-                        while (await enumerator.MoveNext(cancellationToken)
+                        while (await enumerator.MoveNextAsync(cancellationToken)
                                                .ConfigureAwait(false))
                         {
                             var element = enumerator.Current;
@@ -263,7 +263,7 @@ namespace System.Linq
                         break;
 
                     case AsyncIteratorState.Iterating:
-                        if (doMoveNext && await enumerator.MoveNext(cancellationToken)
+                        if (doMoveNext && await enumerator.MoveNextAsync(cancellationToken)
                                                           .ConfigureAwait(false))
                         {
                             current = enumerator.Current;
@@ -327,7 +327,7 @@ namespace System.Linq
                         index = -1;
 
                         // skip elements as requested
-                        while (await enumerator.MoveNext(cancellationToken)
+                        while (await enumerator.MoveNextAsync(cancellationToken)
                                                .ConfigureAwait(false))
                         {
                             checked
@@ -346,7 +346,7 @@ namespace System.Linq
                         break;
 
                     case AsyncIteratorState.Iterating:
-                        if (doMoveNext && await enumerator.MoveNext(cancellationToken)
+                        if (doMoveNext && await enumerator.MoveNextAsync(cancellationToken)
                                                           .ConfigureAwait(false))
                         {
                             current = enumerator.Current;

Ix.NET/Source/System.Interactive.Async/Take.cs

@@ -102,7 +102,7 @@ namespace System.Linq
                         goto case AsyncIteratorState.Iterating;
 
                     case AsyncIteratorState.Iterating:
-                        if (currentCount > 0 && await enumerator.MoveNext(cancellationToken)
+                        if (currentCount > 0 && await enumerator.MoveNextAsync(cancellationToken)
                                                                 .ConfigureAwait(false))
                         {
                             current = enumerator.Current;
@@ -171,7 +171,7 @@ namespace System.Linq
                         {
                             if (!isDone)
                             {
-                                if (await enumerator.MoveNext(cancellationToken)
+                                if (await enumerator.MoveNextAsync(cancellationToken)
                                                     .ConfigureAwait(false))
                                 {
                                     if (count > 0)
@@ -256,7 +256,7 @@ namespace System.Linq
 
 
                     case AsyncIteratorState.Iterating:
-                        if (await enumerator.MoveNext(cancellationToken)
+                        if (await enumerator.MoveNextAsync(cancellationToken)
                                             .ConfigureAwait(false))
                         {
                             var item = enumerator.Current;
@@ -321,7 +321,7 @@ namespace System.Linq
 
 
                     case AsyncIteratorState.Iterating:
-                        if (await enumerator.MoveNext(cancellationToken)
+                        if (await enumerator.MoveNextAsync(cancellationToken)
                                             .ConfigureAwait(false))
                         {
                             var item = enumerator.Current;

Ix.NET/Source/System.Interactive.Async/ToAsyncEnumerable.cs

@@ -67,7 +67,7 @@ namespace System.Linq
             {
                 while (true)
                 {
-                    if (!e.MoveNext(CancellationToken.None)
+                    if (!e.MoveNextAsync(CancellationToken.None)
                           .Result)
                         break;
                     var c = e.Current;

Ix.NET/Source/System.Interactive.Async/ToObservable.cs

@@ -185,7 +185,7 @@ namespace System.Linq
                 var e = source.GetAsyncEnumerator();
 
                 var f = default(Action);
-                f = () => e.MoveNext(ctd.Token)
+                f = () => e.MoveNextAsync(ctd.Token)
                            .ContinueWith(t =>
                                          {
                                              if (t.IsFaulted)

Ix.NET/Source/System.Interactive.Async/Using.cs

@@ -71,7 +71,7 @@ namespace System.Linq
                         goto case AsyncIteratorState.Iterating;
 
                     case AsyncIteratorState.Iterating:
-                        while (await enumerator.MoveNext(cancellationToken)
+                        while (await enumerator.MoveNextAsync(cancellationToken)
                                                .ConfigureAwait(false))
                         {
                             current = enumerator.Current;

Ix.NET/Source/System.Interactive.Async/Where.cs

@@ -93,7 +93,7 @@ namespace System.Linq
                         goto case AsyncIteratorState.Iterating;
 
                     case AsyncIteratorState.Iterating:
-                        while (await enumerator.MoveNext(cancellationToken)
+                        while (await enumerator.MoveNextAsync(cancellationToken)
                                                .ConfigureAwait(false))
                         {
                             var item = enumerator.Current;
@@ -155,7 +155,7 @@ namespace System.Linq
                         goto case AsyncIteratorState.Iterating;
 
                     case AsyncIteratorState.Iterating:
-                        while (await enumerator.MoveNext(cancellationToken)
+                        while (await enumerator.MoveNextAsync(cancellationToken)
                                                .ConfigureAwait(false))
                         {
                             checked
@@ -228,7 +228,7 @@ namespace System.Linq
                         goto case AsyncIteratorState.Iterating;
 
                     case AsyncIteratorState.Iterating:
-                        while (await enumerator.MoveNext(cancellationToken)
+                        while (await enumerator.MoveNextAsync(cancellationToken)
                                                .ConfigureAwait(false))
                         {
                             var item = enumerator.Current;

Ix.NET/Source/System.Interactive.Async/Zip.cs

@@ -78,8 +78,8 @@ namespace System.Linq
                     case AsyncIteratorState.Iterating:
 
                         // We kick these off and join so they can potentially run in parallel
-                        var ft = firstEnumerator.MoveNext(cancellationToken);
-                        var st = secondEnumerator.MoveNext(cancellationToken);
+                        var ft = firstEnumerator.MoveNextAsync(cancellationToken);
+                        var st = secondEnumerator.MoveNextAsync(cancellationToken);
                         await Task.WhenAll(ft, st)
                                   .ConfigureAwait(false);
 

Ix.NET/Source/Tests/AsyncTests.Bugs.cs

@@ -160,7 +160,7 @@ namespace Tests
 
             var e = ys.GetAsyncEnumerator();
             var cts = new CancellationTokenSource();
-            var t = e.MoveNext(cts.Token);
+            var t = e.MoveNextAsync(cts.Token);
 
             cts.Cancel();
 
@@ -195,7 +195,7 @@ namespace Tests
 
             var e = xs.GetAsyncEnumerator();
             var cts = new CancellationTokenSource();
-            var t = e.MoveNext(cts.Token);
+            var t = e.MoveNextAsync(cts.Token);
 
             cts.Cancel();
 
@@ -244,7 +244,7 @@ namespace Tests
 
                 public int Current => i;
                 
-                public async Task<bool> MoveNext(CancellationToken cancellationToken)
+                public async Task<bool> MoveNextAsync(CancellationToken cancellationToken)
                 {
                     LastToken = cancellationToken;
                     MoveNextWasCalled = true;
@@ -322,7 +322,7 @@ namespace Tests
                 () =>
                 {
                     // This call *will* block
-                    t = e.MoveNext(cts.Token);
+                    t = e.MoveNextAsync(cts.Token);
                 });
          
 
@@ -416,7 +416,7 @@ namespace Tests
                     _disposeCounter.DisposeCount++;
                 }
 
-                public Task<bool> MoveNext(CancellationToken _)
+                public Task<bool> MoveNextAsync(CancellationToken _)
                 {
                     return Task.Factory.StartNew(() => false);
                 }
@@ -442,7 +442,7 @@ namespace Tests
             return AsyncEnumerable.CreateEnumerable<T>(() =>
             {
                 var e = source.GetAsyncEnumerator();
-                return AsyncEnumerable.CreateEnumerator<T>(e.MoveNext, () => e.Current, () => { e.Dispose(); a(); });
+                return AsyncEnumerable.CreateEnumerator<T>(e.MoveNextAsync, () => e.Current, () => { e.Dispose(); a(); });
             });
         }
 

Ix.NET/Source/Tests/AsyncTests.Creation.cs

@@ -418,7 +418,7 @@ namespace Tests
             HasNext(e, 1);
 
             var cts = new CancellationTokenSource();
-            var t = e.MoveNext(cts.Token);
+            var t = e.MoveNextAsync(cts.Token);
             cts.Cancel();
 
             try

Ix.NET/Source/Tests/AsyncTests.Exceptions.cs

@@ -404,7 +404,7 @@ namespace Tests
 
             var cts = new CancellationTokenSource();
 
-            var t = e.MoveNext(cts.Token);
+            var t = e.MoveNextAsync(cts.Token);
             cts.Cancel();
             t.Wait(WaitTimeoutMs);