Some renames.

AsyncRx.NET/System.Reactive.Async.Linq/System/Reactive/Linq/Operators/GroupByUntil.cs

@@ -537,12 +537,12 @@ namespace System.Reactive.Linq
             if (comparer == null)
                 throw new ArgumentNullException(nameof(comparer));
 
-            return Core();
+            return CoreAsync();
 
             // REVIEW: Concurrent execution of a duration callback and an event could lead to an OnNext call being queued in an AsyncLockObserver
             //         after a duration callback makes an OnCompleted call. This seems to be the case in sync Rx as well.
 
-            async Task<(IAsyncObserver<TSource>, IAsyncDisposable)> Core()
+            async Task<(IAsyncObserver<TSource>, IAsyncDisposable)> CoreAsync()
             {
                 var d = new CompositeAsyncDisposable();
 

AsyncRx.NET/System.Reactive.Async.Linq/System/Reactive/Linq/Operators/Prepend.cs

@@ -88,9 +88,9 @@ namespace System.Reactive.Linq
             if (observer == null)
                 throw new ArgumentNullException(nameof(observer));
 
-            return Core();
+            return CoreAsync();
 
-            async Task<IAsyncObserver<TSource>> Core()
+            async Task<IAsyncObserver<TSource>> CoreAsync()
             {
                 await observer.OnNextAsync(value).ConfigureAwait(false);
 
@@ -107,9 +107,9 @@ namespace System.Reactive.Linq
             if (scheduler == null)
                 throw new ArgumentNullException(nameof(scheduler));
 
-            return Core();
+            return CoreAsync();
 
-            async Task<IAsyncDisposable> Core()
+            async Task<IAsyncDisposable> CoreAsync()
             {
                 var subscription = new SingleAssignmentAsyncDisposable();
 
@@ -138,9 +138,9 @@ namespace System.Reactive.Linq
             if (values == null)
                 throw new ArgumentNullException(nameof(values));
 
-            return Core();
+            return CoreAsync();
 
-            async Task<IAsyncObserver<TSource>> Core()
+            async Task<IAsyncObserver<TSource>> CoreAsync()
             {
                 foreach (var value in values)
                 {
@@ -162,9 +162,9 @@ namespace System.Reactive.Linq
             if (values == null)
                 throw new ArgumentNullException(nameof(values));
 
-            return Core();
+            return CoreAsync();
 
-            async Task<IAsyncDisposable> Core()
+            async Task<IAsyncDisposable> CoreAsync()
             {
                 var subscription = new SingleAssignmentAsyncDisposable();
 
@@ -196,9 +196,9 @@ namespace System.Reactive.Linq
             if (values == null)
                 throw new ArgumentNullException(nameof(values));
 
-            return Core();
+            return CoreAsync();
 
-            async Task<IAsyncObserver<TSource>> Core()
+            async Task<IAsyncObserver<TSource>> CoreAsync()
             {
                 foreach (var value in values)
                 {
@@ -220,9 +220,9 @@ namespace System.Reactive.Linq
             if (values == null)
                 throw new ArgumentNullException(nameof(values));
 
-            return Core();
+            return CoreAsync();
 
-            async Task<IAsyncDisposable> Core()
+            async Task<IAsyncDisposable> CoreAsync()
             {
                 var subscription = new SingleAssignmentAsyncDisposable();