Remove CancellationToken from MoveNextCore.

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

@@ -60,7 +60,7 @@ namespace System.Linq
             public abstract AppendPrepentAsyncIterator<TSource> Append(TSource item);
             public abstract AppendPrepentAsyncIterator<TSource> Prepend(TSource item);
 
-            protected async Task<bool> LoadFromEnumerator(CancellationToken cancellationToken)
+            protected async Task<bool> LoadFromEnumerator()
             {
                 if (await enumerator.MoveNextAsync()
                                     .ConfigureAwait(false))
@@ -111,7 +111,7 @@ namespace System.Linq
             }
 
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
@@ -135,7 +135,7 @@ namespace System.Linq
 
                         if (enumerator != null)
                         {
-                            if (await LoadFromEnumerator(cancellationToken)
+                            if (await LoadFromEnumerator()
                                 .ConfigureAwait(false))
                             {
                                 return true;
@@ -341,7 +341,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
@@ -371,7 +371,7 @@ namespace System.Linq
                                 goto case 3;
 
                             case 3:
-                                if (await LoadFromEnumerator(cancellationToken)
+                                if (await LoadFromEnumerator()
                                         .ConfigureAwait(false))
                                 {
                                     return true;

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

@@ -48,7 +48,7 @@ namespace System.Linq
         {
             return CreateEnumerable(
                 () => CreateEnumerator<TValue>(
-                    (ct, tcs) => tcs.Task,
+                    tcs => tcs.Task,
                     null,
                     null)
             );

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

@@ -86,7 +86,7 @@ namespace System.Linq
 
                 try
                 {
-                    var result = await MoveNextCore(default(CancellationToken))
+                    var result = await MoveNextCore()
                                         .ConfigureAwait(false);
 
                     currentIsInvalid = !result; // if move next is false, invalid otherwise valid
@@ -113,7 +113,7 @@ namespace System.Linq
                 return new WhereEnumerableAsyncIterator<TSource>(this, predicate);
             }
 
-            protected abstract Task<bool> MoveNextCore(CancellationToken cancellationToken);
+            protected abstract Task<bool> MoveNextCore();
 
             protected virtual void OnGetEnumerator()
             {

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

@@ -71,7 +71,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {

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

@@ -87,7 +87,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
@@ -184,7 +184,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {

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

@@ -86,7 +86,7 @@ namespace System.Linq
             const int State_OuterNext = 1;
             const int State_While = 4;
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
 
                 switch (state)
@@ -240,7 +240,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 if (state == AsyncIteratorState.Allocated)
                 {

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

@@ -19,7 +19,7 @@ namespace System.Linq
             return new AnonymousAsyncEnumerable<T>(getEnumerator);
         }
 
-        public static IAsyncEnumerator<T> CreateEnumerator<T>(Func<CancellationToken, Task<bool>> moveNext, Func<T> current, Action dispose)
+        public static IAsyncEnumerator<T> CreateEnumerator<T>(Func<Task<bool>> moveNext, Func<T> current, Action dispose)
         {
             if (moveNext == null)
                 throw new ArgumentNullException(nameof(moveNext));
@@ -29,10 +29,10 @@ namespace System.Linq
             return new AnonymousAsyncIterator<T>(moveNext, current, dispose);
         }
 
-        private static IAsyncEnumerator<T> CreateEnumerator<T>(Func<CancellationToken, TaskCompletionSource<bool>, Task<bool>> moveNext, Func<T> current, Action dispose)
+        private static IAsyncEnumerator<T> CreateEnumerator<T>(Func<TaskCompletionSource<bool>, Task<bool>> moveNext, Func<T> current, Action dispose)
         {
             var self = new AnonymousAsyncIterator<T>(
-                async ct =>
+                async () =>
                 {
                     var tcs = new TaskCompletionSource<bool>();
 
@@ -42,11 +42,8 @@ namespace System.Linq
                             tcs.TrySetCanceled();
                         });
 
-                    using (ct.Register(stop))
-                    {
-                        return await moveNext(ct, tcs)
-                                   .ConfigureAwait(false);
-                    }
+                    return await moveNext(tcs)
+                                .ConfigureAwait(false);
                 },
                 current,
                 dispose
@@ -75,10 +72,10 @@ namespace System.Linq
         {
             private readonly Func<T> currentFunc;
             private readonly Action dispose;
-            private readonly Func<CancellationToken, Task<bool>> moveNext;
+            private readonly Func<Task<bool>> moveNext;
 
 
-            public AnonymousAsyncIterator(Func<CancellationToken, Task<bool>> moveNext, Func<T> currentFunc, Action dispose)
+            public AnonymousAsyncIterator(Func<Task<bool>> moveNext, Func<T> currentFunc, Action dispose)
             {
                 Debug.Assert(moveNext != null);
 
@@ -102,7 +99,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
@@ -111,7 +108,7 @@ namespace System.Linq
                         goto case AsyncIteratorState.Iterating;
 
                     case AsyncIteratorState.Iterating:
-                        if (await moveNext(cancellationToken).ConfigureAwait(false))
+                        if (await moveNext().ConfigureAwait(false))
                         {
                             current = currentFunc();
                             return true;

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

@@ -59,7 +59,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {

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

@@ -172,7 +172,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
@@ -285,7 +285,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
@@ -375,7 +375,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
@@ -446,7 +446,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {

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

@@ -110,7 +110,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {

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

@@ -75,7 +75,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
@@ -83,7 +83,7 @@ namespace System.Linq
                         firstEnumerator = first.GetAsyncEnumerator();
                         set = new Set<TSource>(comparer);
                         setFilled = false;
-                        fillSetTask = FillSet(cancellationToken);
+                        fillSetTask = FillSet();
 
                         state = AsyncIteratorState.Iterating;
                         goto case AsyncIteratorState.Iterating;
@@ -127,9 +127,9 @@ namespace System.Linq
                 return false;
             }
 
-            private async Task FillSet(CancellationToken cancellationToken)
+            private async Task FillSet()
             {
-                var array = await second.ToArray(cancellationToken)
+                var array = await second.ToArray()
                                         .ConfigureAwait(false);
                 foreach (var t in array)
                 {

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

@@ -57,7 +57,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {

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

@@ -55,7 +55,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {

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

@@ -58,7 +58,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override Task<bool> MoveNextCore()
             {
                 switch (state)
                 {

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

@@ -159,12 +159,12 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
                     case AsyncIteratorState.Allocated:
-                        lookup = await Internal.Lookup<TKey, TSource>.CreateAsync(source, keySelector, comparer, cancellationToken).ConfigureAwait(false);
+                        lookup = await Internal.Lookup<TKey, TSource>.CreateAsync(source, keySelector, comparer).ConfigureAwait(false);
                         enumerator = lookup.ApplyResultSelector(resultSelector).GetEnumerator();
                         state = AsyncIteratorState.Iterating;
                         goto case AsyncIteratorState.Iterating;
@@ -185,13 +185,13 @@ namespace System.Linq
 
             public async Task<TResult[]> ToArrayAsync(CancellationToken cancellationToken)
             {
-                var l = await Internal.Lookup<TKey, TSource>.CreateAsync(source, keySelector, comparer, cancellationToken).ConfigureAwait(false);
+                var l = await Internal.Lookup<TKey, TSource>.CreateAsync(source, keySelector, comparer).ConfigureAwait(false);
                 return l.ToArray(resultSelector);
             }
 
             public async Task<List<TResult>> ToListAsync(CancellationToken cancellationToken)
             {
-                var l = await Internal.Lookup<TKey, TSource>.CreateAsync(source, keySelector, comparer, cancellationToken).ConfigureAwait(false);
+                var l = await Internal.Lookup<TKey, TSource>.CreateAsync(source, keySelector, comparer).ConfigureAwait(false);
                 return l.ToList(resultSelector);
             }
 
@@ -202,7 +202,7 @@ namespace System.Linq
                     return -1;
                 }
 
-                var l = await Internal.Lookup<TKey, TSource>.CreateAsync(source, keySelector, comparer, cancellationToken).ConfigureAwait(false);
+                var l = await Internal.Lookup<TKey, TSource>.CreateAsync(source, keySelector, comparer).ConfigureAwait(false);
 
                 return l.Count;
             }
@@ -248,12 +248,12 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
                     case AsyncIteratorState.Allocated:
-                        lookup = await Internal.Lookup<TKey, TElement>.CreateAsync(source, keySelector, elementSelector, comparer, cancellationToken).ConfigureAwait(false);
+                        lookup = await Internal.Lookup<TKey, TElement>.CreateAsync(source, keySelector, elementSelector, comparer).ConfigureAwait(false);
                         enumerator = lookup.GetEnumerator();
                         state = AsyncIteratorState.Iterating;
                         goto case AsyncIteratorState.Iterating;
@@ -274,13 +274,13 @@ namespace System.Linq
             
             public async Task<IAsyncGrouping<TKey, TElement>[]> ToArrayAsync(CancellationToken cancellationToken)
             {
-                IIListProvider<IAsyncGrouping<TKey, TElement>> l = await Internal.Lookup<TKey, TElement>.CreateAsync(source, keySelector, elementSelector, comparer, cancellationToken).ConfigureAwait(false);
+                IIListProvider<IAsyncGrouping<TKey, TElement>> l = await Internal.Lookup<TKey, TElement>.CreateAsync(source, keySelector, elementSelector, comparer).ConfigureAwait(false);
                 return await l.ToArrayAsync(cancellationToken).ConfigureAwait(false);
             }
 
             public async Task<List<IAsyncGrouping<TKey, TElement>>> ToListAsync(CancellationToken cancellationToken)
             {
-                IIListProvider<IAsyncGrouping<TKey, TElement>> l = await Internal.Lookup<TKey, TElement>.CreateAsync(source, keySelector, elementSelector, comparer, cancellationToken).ConfigureAwait(false);
+                IIListProvider<IAsyncGrouping<TKey, TElement>> l = await Internal.Lookup<TKey, TElement>.CreateAsync(source, keySelector, elementSelector, comparer).ConfigureAwait(false);
                 return await l.ToListAsync(cancellationToken).ConfigureAwait(false);
             }
 
@@ -291,7 +291,7 @@ namespace System.Linq
                     return -1;
                 }
 
-                var l = await Internal.Lookup<TKey, TElement>.CreateAsync(source, keySelector, elementSelector, comparer, cancellationToken).ConfigureAwait(false);
+                var l = await Internal.Lookup<TKey, TElement>.CreateAsync(source, keySelector, elementSelector, comparer).ConfigureAwait(false);
 
                 return l.Count;
             }
@@ -333,12 +333,12 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
                     case AsyncIteratorState.Allocated:
-                        lookup = await Internal.Lookup<TKey, TSource>.CreateAsync(source, keySelector, comparer, cancellationToken).ConfigureAwait(false);
+                        lookup = await Internal.Lookup<TKey, TSource>.CreateAsync(source, keySelector, comparer).ConfigureAwait(false);
                         enumerator = lookup.GetEnumerator();
                         state = AsyncIteratorState.Iterating;
                         goto case AsyncIteratorState.Iterating;
@@ -359,13 +359,13 @@ namespace System.Linq
 
             public async Task<IAsyncGrouping<TKey, TSource>[]> ToArrayAsync(CancellationToken cancellationToken)
             {
-                IIListProvider<IAsyncGrouping<TKey, TSource>> l = await Internal.Lookup<TKey, TSource>.CreateAsync(source, keySelector, comparer, cancellationToken).ConfigureAwait(false);
+                IIListProvider<IAsyncGrouping<TKey, TSource>> l = await Internal.Lookup<TKey, TSource>.CreateAsync(source, keySelector, comparer).ConfigureAwait(false);
                 return await l.ToArrayAsync(cancellationToken).ConfigureAwait(false);
             }
 
             public async Task<List<IAsyncGrouping<TKey, TSource>>> ToListAsync(CancellationToken cancellationToken)
             {
-                IIListProvider<IAsyncGrouping<TKey, TSource>> l = await Internal.Lookup<TKey, TSource>.CreateAsync(source, keySelector, comparer, cancellationToken).ConfigureAwait(false);
+                IIListProvider<IAsyncGrouping<TKey, TSource>> l = await Internal.Lookup<TKey, TSource>.CreateAsync(source, keySelector, comparer).ConfigureAwait(false);
                 return await l.ToListAsync(cancellationToken).ConfigureAwait(false);
             }
 
@@ -376,7 +376,7 @@ namespace System.Linq
                     return -1;
                 }
 
-                var l = await Internal.Lookup<TKey, TSource>.CreateAsync(source, keySelector, comparer, cancellationToken).ConfigureAwait(false);
+                var l = await Internal.Lookup<TKey, TSource>.CreateAsync(source, keySelector, comparer).ConfigureAwait(false);
 
                 return l.Count;
             }

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

@@ -47,7 +47,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {

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

@@ -76,7 +76,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
@@ -84,7 +84,7 @@ namespace System.Linq
                         firstEnumerator = first.GetAsyncEnumerator();
                         set = new Set<TSource>(comparer);
                         setFilled = false;
-                        fillSetTask = FillSet(cancellationToken);
+                        fillSetTask = FillSet();
 
                         state = AsyncIteratorState.Iterating;
                         goto case AsyncIteratorState.Iterating;
@@ -127,9 +127,9 @@ namespace System.Linq
                 return false;
             }
 
-            private async Task FillSet(CancellationToken cancellationToken)
+            private async Task FillSet()
             {
-                var array = await second.ToArray(cancellationToken)
+                var array = await second.ToArray()
                                         .ConfigureAwait(false);
                 for (var i = 0; i < array.Length; i++)
                 {

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

@@ -102,7 +102,7 @@ namespace System.Linq
             const int State_For = 3;
             const int State_While = 4;
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {

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

@@ -74,7 +74,7 @@ namespace System.Linq
             if (comparer == null)
                 throw new ArgumentNullException(nameof(comparer));
 
-            var lookup = await Internal.Lookup<TKey, TElement>.CreateAsync(source, keySelector, elementSelector, comparer, cancellationToken)
+            var lookup = await Internal.Lookup<TKey, TElement>.CreateAsync(source, keySelector, elementSelector, comparer)
                                        .ConfigureAwait(false);
 
             return lookup;
@@ -189,7 +189,7 @@ namespace System.Linq.Internal
             }
         }
         
-        internal static async Task<Lookup<TKey, TElement>> CreateAsync<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, IEqualityComparer<TKey> comparer, CancellationToken cancellationToken)
+        internal static async Task<Lookup<TKey, TElement>> CreateAsync<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, IEqualityComparer<TKey> comparer)
         {
             Debug.Assert(source != null);
             Debug.Assert(keySelector != null);
@@ -209,7 +209,7 @@ namespace System.Linq.Internal
             return lookup;
         }
 
-        internal static async Task<Lookup<TKey, TElement>> CreateAsync(IAsyncEnumerable<TElement> source, Func<TElement, TKey> keySelector,  IEqualityComparer<TKey> comparer, CancellationToken cancellationToken)
+        internal static async Task<Lookup<TKey, TElement>> CreateAsync(IAsyncEnumerable<TElement> source, Func<TElement, TKey> keySelector,  IEqualityComparer<TKey> comparer)
         {
             Debug.Assert(source != null);
             Debug.Assert(keySelector != null);

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

@@ -80,7 +80,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {

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

@@ -19,7 +19,7 @@ namespace System.Linq
             return new OrderedAsyncEnumerable<TElement, TKey>(source, keySelector, comparer, descending, this);
         }
 
-        internal abstract Task Initialize(CancellationToken cancellationToken);
+        internal abstract Task Initialize();
     }
 
     internal sealed class OrderedAsyncEnumerable<TElement, TKey> : OrderedAsyncEnumerable<TElement>
@@ -67,13 +67,13 @@ namespace System.Linq
             base.Dispose();
         }
 
-        protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+        protected override async Task<bool> MoveNextCore()
         {
             switch (state)
             {
                 case AsyncEnumerable.AsyncIteratorState.Allocated:
 
-                    await Initialize(cancellationToken)
+                    await Initialize()
                         .ConfigureAwait(false);
 
                     enumerator = enumerable.GetEnumerator();
@@ -94,18 +94,18 @@ namespace System.Linq
             return false;
         }
 
-        internal override async Task Initialize(CancellationToken cancellationToken)
+        internal override async Task Initialize()
         {
             if (parent == null)
             {
-                var buffer = await source.ToList(cancellationToken)
+                var buffer = await source.ToList()
                                          .ConfigureAwait(false);
                 enumerable = (!@descending ? buffer.OrderBy(keySelector, comparer) : buffer.OrderByDescending(keySelector, comparer));
             }
             else
             {
                 parentEnumerator = parent.GetAsyncEnumerator();
-                await parent.Initialize(cancellationToken)
+                await parent.Initialize()
                             .ConfigureAwait(false);
                 enumerable = parent.enumerable.CreateOrderedEnumerable(keySelector, comparer, @descending);
             }

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

@@ -57,7 +57,7 @@ namespace System.Linq
                 return new RepeatElementAsyncIterator<TResult>(element);
             }
 
-            protected override Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override Task<bool> MoveNextCore()
             {
                 current = element;
                 return TaskExt.True;
@@ -99,7 +99,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {

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

@@ -90,12 +90,12 @@ namespace System.Linq
             }
 
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
                     case AsyncIteratorState.Allocated:
-                        items = await source.ToArray(cancellationToken)
+                        items = await source.ToArray()
                                             .ConfigureAwait(false);
                         index = items.Length - 1;
 

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

@@ -67,7 +67,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
@@ -133,7 +133,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {

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

@@ -83,7 +83,7 @@ namespace System.Linq
                 return new SelectEnumerableAsyncIterator<TSource, TResult1>(source, CombineSelectors(this.selector, selector));
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
@@ -140,7 +140,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
@@ -206,7 +206,7 @@ namespace System.Linq
                 return new SelectIListIterator<TSource, TResult1>(source, CombineSelectors(this.selector, selector));
             }
 
-            protected override Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override Task<bool> MoveNextCore()
             {
                 switch (state)
                 {

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

@@ -109,7 +109,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
@@ -204,7 +204,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
@@ -301,7 +301,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
@@ -399,7 +399,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {

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

@@ -105,7 +105,7 @@ namespace System.Linq
             }
 
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
@@ -175,7 +175,7 @@ namespace System.Linq
             }
 
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
@@ -241,7 +241,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
@@ -318,7 +318,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {

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

@@ -91,7 +91,7 @@ namespace System.Linq
             }
 
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
@@ -153,7 +153,7 @@ namespace System.Linq
             }
 
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
@@ -244,7 +244,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
@@ -309,7 +309,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {

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

@@ -105,7 +105,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
@@ -174,7 +174,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
@@ -276,7 +276,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override Task<bool> MoveNextCore()
             {
                 switch (state)
                 {

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

@@ -24,7 +24,7 @@ namespace System.Linq
                     var subscription = source.Subscribe(observer);
 
                     return CreateEnumerator(
-                        (ct, tcs) =>
+                        tcs =>
                         {
                             var hasValue = false;
                             var hasCompleted = false;

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

@@ -61,7 +61,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {

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

@@ -83,7 +83,7 @@ namespace System.Linq
                 return new WhereEnumerableAsyncIterator<TSource>(source, CombinePredicates(this.predicate, predicate));
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
@@ -144,7 +144,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {
@@ -218,7 +218,7 @@ namespace System.Linq
                 return new WhereSelectEnumerableAsyncIterator<TSource, TResult1>(source, predicate, CombineSelectors(this.selector, selector));
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {

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

@@ -64,7 +64,7 @@ namespace System.Linq
                 base.Dispose();
             }
 
-            protected override async Task<bool> MoveNextCore(CancellationToken cancellationToken)
+            protected override async Task<bool> MoveNextCore()
             {
                 switch (state)
                 {

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

@@ -451,7 +451,7 @@ namespace Tests
 
             var ae = AsyncEnumerable.CreateEnumerable(
                 () => AsyncEnumerable.CreateEnumerator<int>(
-                    ct => Task.FromResult(false),
+                    () => Task.FromResult(false),
                     () => { throw new InvalidOperationException(); },
                     () => { evt.Set(); }));
 
@@ -485,7 +485,7 @@ namespace Tests
 
             var ae = AsyncEnumerable.CreateEnumerable(
                 () => AsyncEnumerable.CreateEnumerator(
-                    async ct =>
+                    async () =>
                     {
                         await subscriptionAssignedTcs.Task;
                         return true;
@@ -527,7 +527,7 @@ namespace Tests
 
             var ae = AsyncEnumerable.CreateEnumerable(
                 () => AsyncEnumerable.CreateEnumerator(
-                    async ct =>
+                    async () =>
                     {
                         await subscriptionAssignedTcs.Task;
 

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

@@ -27,7 +27,7 @@ namespace Tests
         public void Create_Iterator_Throws()
         {
      
-           var iter = AsyncEnumerable.CreateEnumerator<int>(c => Task.FromResult(true), () => 3, () => { });
+           var iter = AsyncEnumerable.CreateEnumerator<int>(() => Task.FromResult(true), () => 3, () => { });
 
             var enu = (IAsyncEnumerable<int>)iter;