Browse Source

Replace observable with async-enumerable in docs

akarnokd 6 years ago
parent
commit
05e5afae94
28 changed files with 230 additions and 230 deletions
  1. 8 8
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Amb.cs
  2. 4 4
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Buffer.cs
  3. 17 17
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Catch.cs
  4. 7 7
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Concat.cs
  5. 7 7
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Defer.cs
  6. 18 18
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Distinct.cs
  7. 24 24
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/DistinctUntilChanged.cs
  8. 36 36
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Do.cs
  9. 4 4
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Finally.cs
  10. 1 1
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Generate.cs
  11. 2 2
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/IgnoreElements.cs
  12. 3 3
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/IsEmpty.cs
  13. 3 3
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Max.cs
  14. 12 12
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/MaxBy.cs
  15. 8 8
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Merge.cs
  16. 3 3
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Min.cs
  17. 12 12
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/MinBy.cs
  18. 2 2
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Never.cs
  19. 8 8
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/OnErrorResumeNext.cs
  20. 7 7
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Repeat.cs
  21. 4 4
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Retry.cs
  22. 3 3
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Return.cs
  23. 18 18
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Scan.cs
  24. 4 4
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/SelectMany.cs
  25. 1 1
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/StartWith.cs
  26. 2 2
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Throw.cs
  27. 1 1
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Timeout.cs
  28. 11 11
      Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Using.cs

+ 8 - 8
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Amb.cs

@@ -11,12 +11,12 @@ namespace System.Linq
     public static partial class AsyncEnumerableEx
     {
         /// <summary>
-        /// Propagates the observable sequence that reacts first.
+        /// Propagates the async-enumerable sequence that reacts first.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequences.</typeparam>
-        /// <param name="first">First observable sequence.</param>
-        /// <param name="second">Second observable sequence.</param>
-        /// <returns>An observable sequence that surfaces either of the given sequences, whichever reacted first.</returns>
+        /// <param name="first">First async-enumerable sequence.</param>
+        /// <param name="second">Second async-enumerable sequence.</param>
+        /// <returns>An async-enumerable sequence that surfaces either of the given sequences, whichever reacted first.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="first"/> or <paramref name="second"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Amb<TSource>(this IAsyncEnumerable<TSource> first, IAsyncEnumerable<TSource> second)
         {
@@ -149,11 +149,11 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Propagates the observable sequence that reacts first.
+        /// Propagates the async-enumerable sequence that reacts first.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequences.</typeparam>
         /// <param name="sources">Observable sources competing to react first.</param>
-        /// <returns>An observable sequence that surfaces any of the given sequences, whichever reacted first.</returns>
+        /// <returns>An async-enumerable sequence that surfaces any of the given sequences, whichever reacted first.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="sources"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Amb<TSource>(params IAsyncEnumerable<TSource>[] sources)
         {
@@ -259,11 +259,11 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Propagates the observable sequence that reacts first.
+        /// Propagates the async-enumerable sequence that reacts first.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequences.</typeparam>
         /// <param name="sources">Observable sources competing to react first.</param>
-        /// <returns>An observable sequence that surfaces any of the given sequences, whichever reacted first.</returns>
+        /// <returns>An async-enumerable sequence that surfaces any of the given sequences, whichever reacted first.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="sources"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Amb<TSource>(this IEnumerable<IAsyncEnumerable<TSource>> sources)
         {

+ 4 - 4
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Buffer.cs

@@ -11,12 +11,12 @@ namespace System.Linq
     public static partial class AsyncEnumerableEx
     {
         /// <summary>
-        /// Projects each element of an observable sequence into consecutive non-overlapping buffers which are produced based on element count information.
+        /// Projects each element of an async-enumerable sequence into consecutive non-overlapping buffers which are produced based on element count information.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence, and in the lists in the result sequence.</typeparam>
         /// <param name="source">Source sequence to produce buffers over.</param>
         /// <param name="count">Length of each buffer.</param>
-        /// <returns>An observable sequence of buffers.</returns>
+        /// <returns>An async-enumerable sequence of buffers.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> is null.</exception>
         /// <exception cref="ArgumentOutOfRangeException"><paramref name="count"/> is less than or equal to zero.</exception>
         public static IAsyncEnumerable<IList<TSource>> Buffer<TSource>(this IAsyncEnumerable<TSource> source, int count)
@@ -52,13 +52,13 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Projects each element of an observable sequence into zero or more buffers which are produced based on element count information.
+        /// Projects each element of an async-enumerable sequence into zero or more buffers which are produced based on element count information.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence, and in the lists in the result sequence.</typeparam>
         /// <param name="source">Source sequence to produce buffers over.</param>
         /// <param name="count">Length of each buffer.</param>
         /// <param name="skip">Number of elements to skip between creation of consecutive buffers.</param>
-        /// <returns>An observable sequence of buffers.</returns>
+        /// <returns>An async-enumerable sequence of buffers.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> is null.</exception>
         /// <exception cref="ArgumentOutOfRangeException"><paramref name="count"/> or <paramref name="skip"/> is less than or equal to zero.</exception>
         public static IAsyncEnumerable<IList<TSource>> Buffer<TSource>(this IAsyncEnumerable<TSource> source, int count, int skip)

+ 17 - 17
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Catch.cs

@@ -17,13 +17,13 @@ namespace System.Linq
         //         catch (TException ex) when(!(ex is OperationCanceledException oce && oce.CancellationToken == cancellationToken))
 
         /// <summary>
-        /// Continues an observable sequence that is terminated by an exception of the specified type with the observable sequence produced by the handler.
+        /// Continues an async-enumerable sequence that is terminated by an exception of the specified type with the async-enumerable sequence produced by the handler.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence and sequences returned by the exception handler function.</typeparam>
         /// <typeparam name="TException">The type of the exception to catch and handle. Needs to derive from <see cref="Exception"/>.</typeparam>
         /// <param name="source">Source sequence.</param>
-        /// <param name="handler">Exception handler function, producing another observable sequence.</param>
-        /// <returns>An observable sequence containing the source sequence's elements, followed by the elements produced by the handler's resulting observable sequence in case an exception occurred.</returns>
+        /// <param name="handler">Exception handler function, producing another async-enumerable sequence.</param>
+        /// <returns>An async-enumerable sequence containing the source sequence's elements, followed by the elements produced by the handler's resulting async-enumerable sequence in case an exception occurred.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="handler"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Catch<TSource, TException>(this IAsyncEnumerable<TSource> source, Func<TException, IAsyncEnumerable<TSource>> handler)
             where TException : Exception
@@ -80,13 +80,13 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Continues an observable sequence that is terminated by an exception of the specified type with the observable sequence produced asynchronously by the handler.
+        /// Continues an async-enumerable sequence that is terminated by an exception of the specified type with the async-enumerable sequence produced asynchronously by the handler.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence and sequences returned by the exception handler function.</typeparam>
         /// <typeparam name="TException">The type of the exception to catch and handle. Needs to derive from <see cref="Exception"/>.</typeparam>
         /// <param name="source">Source sequence.</param>
-        /// <param name="handler">Exception handler function, producing another observable sequence asynchronously.</param>
-        /// <returns>An observable sequence containing the source sequence's elements, followed by the elements produced by the handler's resulting observable sequence in case an exception occurred.</returns>
+        /// <param name="handler">Exception handler function, producing another async-enumerable sequence asynchronously.</param>
+        /// <returns>An async-enumerable sequence containing the source sequence's elements, followed by the elements produced by the handler's resulting async-enumerable sequence in case an exception occurred.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="handler"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Catch<TSource, TException>(this IAsyncEnumerable<TSource> source, Func<TException, ValueTask<IAsyncEnumerable<TSource>>> handler)
             where TException : Exception
@@ -144,13 +144,13 @@ namespace System.Linq
 
 #if !NO_DEEP_CANCELLATION
         /// <summary>
-        /// Continues an observable sequence that is terminated by an exception of the specified type with the observable sequence produced asynchronously (cancellable) by the handler.
+        /// Continues an async-enumerable sequence that is terminated by an exception of the specified type with the async-enumerable sequence produced asynchronously (cancellable) by the handler.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence and sequences returned by the exception handler function.</typeparam>
         /// <typeparam name="TException">The type of the exception to catch and handle. Needs to derive from <see cref="Exception"/>.</typeparam>
         /// <param name="source">Source sequence.</param>
-        /// <param name="handler">Exception handler function, producing another observable sequence asynchronously while supporting cancellation.</param>
-        /// <returns>An observable sequence containing the source sequence's elements, followed by the elements produced by the handler's resulting observable sequence in case an exception occurred.</returns>
+        /// <param name="handler">Exception handler function, producing another async-enumerable sequence asynchronously while supporting cancellation.</param>
+        /// <returns>An async-enumerable sequence containing the source sequence's elements, followed by the elements produced by the handler's resulting async-enumerable sequence in case an exception occurred.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="handler"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Catch<TSource, TException>(this IAsyncEnumerable<TSource> source, Func<TException, CancellationToken, ValueTask<IAsyncEnumerable<TSource>>> handler)
             where TException : Exception
@@ -208,11 +208,11 @@ namespace System.Linq
 #endif
 
         /// <summary>
-        /// Continues an observable sequence that is terminated by an exception with the next observable sequence.
+        /// Continues an async-enumerable sequence that is terminated by an exception with the next async-enumerable sequence.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source and handler sequences.</typeparam>
         /// <param name="sources">Observable sequences to catch exceptions for.</param>
-        /// <returns>An observable sequence containing elements from consecutive source sequences until a source sequence terminates successfully.</returns>
+        /// <returns>An async-enumerable sequence containing elements from consecutive source sequences until a source sequence terminates successfully.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="sources"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Catch<TSource>(this IEnumerable<IAsyncEnumerable<TSource>> sources)
         {
@@ -223,11 +223,11 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Continues an observable sequence that is terminated by an exception with the next observable sequence.
+        /// Continues an async-enumerable sequence that is terminated by an exception with the next async-enumerable sequence.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source and handler sequences.</typeparam>
         /// <param name="sources">Observable sequences to catch exceptions for.</param>
-        /// <returns>An observable sequence containing elements from consecutive source sequences until a source sequence terminates successfully.</returns>
+        /// <returns>An async-enumerable sequence containing elements from consecutive source sequences until a source sequence terminates successfully.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="sources"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Catch<TSource>(params IAsyncEnumerable<TSource>[] sources)
         {
@@ -238,12 +238,12 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Continues an observable sequence that is terminated by an exception with the next observable sequence.
+        /// Continues an async-enumerable sequence that is terminated by an exception with the next async-enumerable sequence.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence and handler sequence.</typeparam>
-        /// <param name="first">First observable sequence whose exception (if any) is caught.</param>
-        /// <param name="second">Second observable sequence used to produce results when an error occurred in the first sequence.</param>
-        /// <returns>An observable sequence containing the first sequence's elements, followed by the elements of the second sequence in case an exception occurred.</returns>
+        /// <param name="first">First async-enumerable sequence whose exception (if any) is caught.</param>
+        /// <param name="second">Second async-enumerable sequence used to produce results when an error occurred in the first sequence.</param>
+        /// <returns>An async-enumerable sequence containing the first sequence's elements, followed by the elements of the second sequence in case an exception occurred.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="first"/> or <paramref name="second"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Catch<TSource>(this IAsyncEnumerable<TSource> first, IAsyncEnumerable<TSource> second)
         {

+ 7 - 7
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Concat.cs

@@ -11,11 +11,11 @@ namespace System.Linq
     public static partial class AsyncEnumerableEx
     {
         /// <summary>
-        /// Concatenates all inner observable sequences, as long as the previous observable sequence terminated successfully.
+        /// Concatenates all inner async-enumerable sequences, as long as the previous async-enumerable sequence terminated successfully.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequences.</typeparam>
-        /// <param name="sources">Observable sequence of inner observable sequences.</param>
-        /// <returns>An observable sequence that contains the elements of each observed inner sequence, in sequential order.</returns>
+        /// <param name="sources">Observable sequence of inner async-enumerable sequences.</param>
+        /// <returns>An async-enumerable sequence that contains the elements of each observed inner sequence, in sequential order.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="sources"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Concat<TSource>(this IAsyncEnumerable<IAsyncEnumerable<TSource>> sources)
         {
@@ -37,11 +37,11 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Concatenates all observable sequences in the given enumerable sequence, as long as the previous observable sequence terminated successfully.
+        /// Concatenates all async-enumerable sequences in the given enumerable sequence, as long as the previous async-enumerable sequence terminated successfully.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequences.</typeparam>
         /// <param name="sources">Observable sequences to concatenate.</param>
-        /// <returns>An observable sequence that contains the elements of each given sequence, in sequential order.</returns>
+        /// <returns>An async-enumerable sequence that contains the elements of each given sequence, in sequential order.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="sources"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Concat<TSource>(this IEnumerable<IAsyncEnumerable<TSource>> sources)
         {
@@ -63,11 +63,11 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Concatenates all of the specified observable sequences, as long as the previous observable sequence terminated successfully.
+        /// Concatenates all of the specified async-enumerable sequences, as long as the previous async-enumerable sequence terminated successfully.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequences.</typeparam>
         /// <param name="sources">Observable sequences to concatenate.</param>
-        /// <returns>An observable sequence that contains the elements of each given sequence, in sequential order.</returns>
+        /// <returns>An async-enumerable sequence that contains the elements of each given sequence, in sequential order.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="sources"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Concat<TSource>(params IAsyncEnumerable<TSource>[] sources)
         {

+ 7 - 7
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Defer.cs

@@ -11,11 +11,11 @@ namespace System.Linq
     public static partial class AsyncEnumerableEx
     {
         /// <summary>
-        /// Returns an observable sequence that invokes the specified factory function whenever a new observer subscribes.
+        /// Returns an async-enumerable sequence that invokes the specified factory function whenever a new observer subscribes.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the sequence returned by the factory function, and in the resulting sequence.</typeparam>
         /// <param name="factory">The async-enumerable factory function to invoke for each consumer that starts enumerating the resulting asynchronous sequence.</param>
-        /// <returns>An observable sequence whose observers trigger an invocation of the given observable factory function.</returns>
+        /// <returns>An async-enumerable sequence whose observers trigger an invocation of the given async-enumerable factory function.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="factory"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Defer<TSource>(Func<IAsyncEnumerable<TSource>> factory)
         {
@@ -34,11 +34,11 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Returns an observable sequence that starts the specified asynchronous factory function whenever a new observer subscribes.
+        /// Returns an async-enumerable sequence that starts the specified asynchronous factory function whenever a new observer subscribes.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the sequence returned by the factory function, and in the resulting sequence.</typeparam>
         /// <param name="factory">Asynchronous factory function to start for each consumer that starts enumerating the resulting asynchronous sequence.</param>
-        /// <returns>An observable sequence whose observers trigger the given asynchronous observable factory function to be started.</returns>
+        /// <returns>An async-enumerable sequence whose observers trigger the given asynchronous async-enumerable factory function to be started.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="factory"/> is null.</exception>
         /// <remarks>This operator is especially useful in conjunction with the asynchronous programming features introduced in C# 5.0 and Visual Basic 11.</remarks>
         public static IAsyncEnumerable<TSource> Defer<TSource>(Func<Task<IAsyncEnumerable<TSource>>> factory)
@@ -59,15 +59,15 @@ namespace System.Linq
 
 #if !NO_DEEP_CANCELLATION
         /// <summary>
-        /// Returns an observable sequence that starts the specified cancellable asynchronous factory function whenever a new observer subscribes.
+        /// Returns an async-enumerable sequence that starts the specified cancellable asynchronous factory function whenever a new observer subscribes.
         /// The CancellationToken passed to the asynchronous factory function is tied to the returned disposable subscription, allowing best-effort cancellation.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the sequence returned by the factory function, and in the resulting sequence.</typeparam>
         /// <param name="factory">Asynchronous factory function, supporting cancellation, to start for each consumer that starts enumerating the resulting asynchronous sequence.</param>
-        /// <returns>An observable sequence whose observers trigger the given asynchronous observable factory function to be started.</returns>
+        /// <returns>An async-enumerable sequence whose observers trigger the given asynchronous async-enumerable factory function to be started.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="factory"/> is null.</exception>
         /// <remarks>This operator is especially useful in conjunction with the asynchronous programming features introduced in C# 5.0 and Visual Basic 11.</remarks>
-        /// <remarks>When a subscription to the resulting sequence is disposed, the CancellationToken that was fed to the asynchronous observable factory function will be signaled.</remarks>
+        /// <remarks>When a subscription to the resulting sequence is disposed, the CancellationToken that was fed to the asynchronous async-enumerable factory function will be signaled.</remarks>
         public static IAsyncEnumerable<TSource> Defer<TSource>(Func<CancellationToken, Task<IAsyncEnumerable<TSource>>> factory)
         {
             if (factory == null)

+ 18 - 18
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Distinct.cs

@@ -11,13 +11,13 @@ namespace System.Linq
     public static partial class AsyncEnumerableEx
     {
         /// <summary>
-        /// Returns an observable sequence that contains only distinct elements according to the keySelector.
+        /// Returns an async-enumerable sequence that contains only distinct elements according to the keySelector.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TKey">The type of the discriminator key computed for each element in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to retain distinct elements for.</param>
+        /// <param name="source">An async-enumerable sequence to retain distinct elements for.</param>
         /// <param name="keySelector">A function to compute the comparison key for each element.</param>
-        /// <returns>An observable sequence only containing the distinct elements, based on a computed key value, from the source sequence.</returns>
+        /// <returns>An async-enumerable sequence only containing the distinct elements, based on a computed key value, from the source sequence.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="keySelector"/> is null.</exception>
         /// <remarks>Usage of this operator should be considered carefully due to the maintenance of an internal lookup structure which can grow large.</remarks>
         public static IAsyncEnumerable<TSource> Distinct<TSource, TKey>(this IAsyncEnumerable<TSource> source, Func<TSource, TKey> keySelector)
@@ -31,14 +31,14 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Returns an observable sequence that contains only distinct elements according to the keySelector and the comparer.
+        /// Returns an async-enumerable sequence that contains only distinct elements according to the keySelector and the comparer.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TKey">The type of the discriminator key computed for each element in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to retain distinct elements for.</param>
+        /// <param name="source">An async-enumerable sequence to retain distinct elements for.</param>
         /// <param name="keySelector">A function to compute the comparison key for each element.</param>
         /// <param name="comparer">Equality comparer for source elements.</param>
-        /// <returns>An observable sequence only containing the distinct elements, based on a computed key value, from the source sequence.</returns>
+        /// <returns>An async-enumerable sequence only containing the distinct elements, based on a computed key value, from the source sequence.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="keySelector"/> or <paramref name="comparer"/> is null.</exception>
         /// <remarks>Usage of this operator should be considered carefully due to the maintenance of an internal lookup structure which can grow large.</remarks>
         public static IAsyncEnumerable<TSource> Distinct<TSource, TKey>(this IAsyncEnumerable<TSource> source, Func<TSource, TKey> keySelector, IEqualityComparer<TKey>? comparer)
@@ -52,13 +52,13 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Returns an observable sequence that contains only distinct elements according to the asynchronous keySelector.
+        /// Returns an async-enumerable sequence that contains only distinct elements according to the asynchronous keySelector.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TKey">The type of the discriminator key computed for each element in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to retain distinct elements for.</param>
+        /// <param name="source">An async-enumerable sequence to retain distinct elements for.</param>
         /// <param name="keySelector">An asynchronous function to compute the comparison key for each element.</param>
-        /// <returns>An observable sequence only containing the distinct elements, based on a computed key value, from the source sequence.</returns>
+        /// <returns>An async-enumerable sequence only containing the distinct elements, based on a computed key value, from the source sequence.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="keySelector"/> is null.</exception>
         /// <remarks>Usage of this operator should be considered carefully due to the maintenance of an internal lookup structure which can grow large.</remarks>
         public static IAsyncEnumerable<TSource> Distinct<TSource, TKey>(this IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<TKey>> keySelector)
@@ -73,13 +73,13 @@ namespace System.Linq
 
 #if !NO_DEEP_CANCELLATION
         /// <summary>
-        /// Returns an observable sequence that contains only distinct elements according to the asynchronous (cancellable) keySelector.
+        /// Returns an async-enumerable sequence that contains only distinct elements according to the asynchronous (cancellable) keySelector.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TKey">The type of the discriminator key computed for each element in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to retain distinct elements for.</param>
+        /// <param name="source">An async-enumerable sequence to retain distinct elements for.</param>
         /// <param name="keySelector">An asynchronous (cancellable) function to compute the comparison key for each element.</param>
-        /// <returns>An observable sequence only containing the distinct elements, based on a computed key value, from the source sequence.</returns>
+        /// <returns>An async-enumerable sequence only containing the distinct elements, based on a computed key value, from the source sequence.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="keySelector"/> is null.</exception>
         /// <remarks>Usage of this operator should be considered carefully due to the maintenance of an internal lookup structure which can grow large.</remarks>
         public static IAsyncEnumerable<TSource> Distinct<TSource, TKey>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<TKey>> keySelector)
@@ -94,14 +94,14 @@ namespace System.Linq
 #endif
 
         /// <summary>
-        /// Returns an observable sequence that contains only distinct elements according to the asynchronous keySelector and the comparer.
+        /// Returns an async-enumerable sequence that contains only distinct elements according to the asynchronous keySelector and the comparer.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TKey">The type of the discriminator key computed for each element in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to retain distinct elements for.</param>
+        /// <param name="source">An async-enumerable sequence to retain distinct elements for.</param>
         /// <param name="keySelector">An asynchronous function to compute the comparison key for each element.</param>
         /// <param name="comparer">Equality comparer for source elements.</param>
-        /// <returns>An observable sequence only containing the distinct elements, based on a computed key value, from the source sequence.</returns>
+        /// <returns>An async-enumerable sequence only containing the distinct elements, based on a computed key value, from the source sequence.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="keySelector"/> or <paramref name="comparer"/> is null.</exception>
         /// <remarks>Usage of this operator should be considered carefully due to the maintenance of an internal lookup structure which can grow large.</remarks>
         public static IAsyncEnumerable<TSource> Distinct<TSource, TKey>(this IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<TKey>> keySelector, IEqualityComparer<TKey>? comparer)
@@ -116,14 +116,14 @@ namespace System.Linq
 
 #if !NO_DEEP_CANCELLATION
         /// <summary>
-        /// Returns an observable sequence that contains only distinct elements according to the asynchronous (cancellable) keySelector and the comparer.
+        /// Returns an async-enumerable sequence that contains only distinct elements according to the asynchronous (cancellable) keySelector and the comparer.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TKey">The type of the discriminator key computed for each element in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to retain distinct elements for.</param>
+        /// <param name="source">An async-enumerable sequence to retain distinct elements for.</param>
         /// <param name="keySelector">An asynchronous (cancellable) function to compute the comparison key for each element.</param>
         /// <param name="comparer">Equality comparer for source elements.</param>
-        /// <returns>An observable sequence only containing the distinct elements, based on a computed key value, from the source sequence.</returns>
+        /// <returns>An async-enumerable sequence only containing the distinct elements, based on a computed key value, from the source sequence.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="keySelector"/> or <paramref name="comparer"/> is null.</exception>
         /// <remarks>Usage of this operator should be considered carefully due to the maintenance of an internal lookup structure which can grow large.</remarks>
         public static IAsyncEnumerable<TSource> Distinct<TSource, TKey>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<TKey>> keySelector, IEqualityComparer<TKey>? comparer)

+ 24 - 24
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/DistinctUntilChanged.cs

@@ -11,11 +11,11 @@ namespace System.Linq
     public static partial class AsyncEnumerableEx
     {
         /// <summary>
-        /// Returns an observable sequence that contains only distinct contiguous elements.
+        /// Returns an async-enumerable sequence that contains only distinct contiguous elements.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to retain distinct contiguous elements for.</param>
-        /// <returns>An observable sequence only containing the distinct contiguous elements from the source sequence.</returns>
+        /// <param name="source">An async-enumerable sequence to retain distinct contiguous elements for.</param>
+        /// <returns>An async-enumerable sequence only containing the distinct contiguous elements from the source sequence.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> is null.</exception>
         public static IAsyncEnumerable<TSource> DistinctUntilChanged<TSource>(this IAsyncEnumerable<TSource> source)
         {
@@ -26,12 +26,12 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Returns an observable sequence that contains only distinct contiguous elements according to the comparer.
+        /// Returns an async-enumerable sequence that contains only distinct contiguous elements according to the comparer.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to retain distinct contiguous elements for.</param>
+        /// <param name="source">An async-enumerable sequence to retain distinct contiguous elements for.</param>
         /// <param name="comparer">Equality comparer for source elements.</param>
-        /// <returns>An observable sequence only containing the distinct contiguous elements from the source sequence.</returns>
+        /// <returns>An async-enumerable sequence only containing the distinct contiguous elements from the source sequence.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="comparer"/> is null.</exception>
         public static IAsyncEnumerable<TSource> DistinctUntilChanged<TSource>(this IAsyncEnumerable<TSource> source, IEqualityComparer<TSource>? comparer)
         {
@@ -42,13 +42,13 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Returns an observable sequence that contains only distinct contiguous elements according to the keySelector.
+        /// Returns an async-enumerable sequence that contains only distinct contiguous elements according to the keySelector.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TKey">The type of the discriminator key computed for each element in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to retain distinct contiguous elements for, based on a computed key value.</param>
+        /// <param name="source">An async-enumerable sequence to retain distinct contiguous elements for, based on a computed key value.</param>
         /// <param name="keySelector">A function to compute the comparison key for each element.</param>
-        /// <returns>An observable sequence only containing the distinct contiguous elements, based on a computed key value, from the source sequence.</returns>
+        /// <returns>An async-enumerable sequence only containing the distinct contiguous elements, based on a computed key value, from the source sequence.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="keySelector"/> is null.</exception>
         public static IAsyncEnumerable<TSource> DistinctUntilChanged<TSource, TKey>(this IAsyncEnumerable<TSource> source, Func<TSource, TKey> keySelector)
         {
@@ -61,14 +61,14 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Returns an observable sequence that contains only distinct contiguous elements according to the keySelector and the comparer.
+        /// Returns an async-enumerable sequence that contains only distinct contiguous elements according to the keySelector and the comparer.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TKey">The type of the discriminator key computed for each element in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to retain distinct contiguous elements for, based on a computed key value.</param>
+        /// <param name="source">An async-enumerable sequence to retain distinct contiguous elements for, based on a computed key value.</param>
         /// <param name="keySelector">A function to compute the comparison key for each element.</param>
         /// <param name="comparer">Equality comparer for computed key values.</param>
-        /// <returns>An observable sequence only containing the distinct contiguous elements, based on a computed key value, from the source sequence.</returns>
+        /// <returns>An async-enumerable sequence only containing the distinct contiguous elements, based on a computed key value, from the source sequence.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="keySelector"/> or <paramref name="comparer"/> is null.</exception>
         public static IAsyncEnumerable<TSource> DistinctUntilChanged<TSource, TKey>(this IAsyncEnumerable<TSource> source, Func<TSource, TKey> keySelector, IEqualityComparer<TKey>? comparer)
         {
@@ -81,13 +81,13 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Returns an observable sequence that contains only distinct contiguous elements according to the asynchronous keySelector.
+        /// Returns an async-enumerable sequence that contains only distinct contiguous elements according to the asynchronous keySelector.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TKey">The type of the discriminator key computed for each element in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to retain distinct contiguous elements for, based on a computed key value.</param>
+        /// <param name="source">An async-enumerable sequence to retain distinct contiguous elements for, based on a computed key value.</param>
         /// <param name="keySelector">A function to compute the comparison key for each element asynchronously.</param>
-        /// <returns>An observable sequence only containing the distinct contiguous elements, based on a computed key value, from the source sequence.</returns>
+        /// <returns>An async-enumerable sequence only containing the distinct contiguous elements, based on a computed key value, from the source sequence.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="keySelector"/> is null.</exception>
         public static IAsyncEnumerable<TSource> DistinctUntilChanged<TSource, TKey>(this IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<TKey>> keySelector)
         {
@@ -101,13 +101,13 @@ namespace System.Linq
 
 #if !NO_DEEP_CANCELLATION
         /// <summary>
-        /// Returns an observable sequence that contains only distinct contiguous elements according to the asynchronous and cancellable keySelector.
+        /// Returns an async-enumerable sequence that contains only distinct contiguous elements according to the asynchronous and cancellable keySelector.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TKey">The type of the discriminator key computed for each element in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to retain distinct contiguous elements for, based on a computed key value.</param>
+        /// <param name="source">An async-enumerable sequence to retain distinct contiguous elements for, based on a computed key value.</param>
         /// <param name="keySelector">A function to compute the comparison key for each element asynchronously while supporting cancellation.</param>
-        /// <returns>An observable sequence only containing the distinct contiguous elements, based on a computed key value, from the source sequence.</returns>
+        /// <returns>An async-enumerable sequence only containing the distinct contiguous elements, based on a computed key value, from the source sequence.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="keySelector"/> is null.</exception>
         public static IAsyncEnumerable<TSource> DistinctUntilChanged<TSource, TKey>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<TKey>> keySelector)
         {
@@ -121,14 +121,14 @@ namespace System.Linq
 #endif
 
         /// <summary>
-        /// Returns an observable sequence that contains only distinct contiguous elements according to the asynchronous keySelector and the comparer.
+        /// Returns an async-enumerable sequence that contains only distinct contiguous elements according to the asynchronous keySelector and the comparer.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TKey">The type of the discriminator key computed for each element in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to retain distinct contiguous elements for, based on a computed key value.</param>
+        /// <param name="source">An async-enumerable sequence to retain distinct contiguous elements for, based on a computed key value.</param>
         /// <param name="keySelector">A function to compute the comparison key for each element asynchronously.</param>
         /// <param name="comparer">Equality comparer for computed key values.</param>
-        /// <returns>An observable sequence only containing the distinct contiguous elements, based on a computed key value, from the source sequence.</returns>
+        /// <returns>An async-enumerable sequence only containing the distinct contiguous elements, based on a computed key value, from the source sequence.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="keySelector"/> or <paramref name="comparer"/> is null.</exception>
         public static IAsyncEnumerable<TSource> DistinctUntilChanged<TSource, TKey>(this IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<TKey>> keySelector, IEqualityComparer<TKey>? comparer)
         {
@@ -142,14 +142,14 @@ namespace System.Linq
 
 #if !NO_DEEP_CANCELLATION
         /// <summary>
-        /// Returns an observable sequence that contains only distinct contiguous elements according to the asynchronous and cancellable keySelector and the comparer.
+        /// Returns an async-enumerable sequence that contains only distinct contiguous elements according to the asynchronous and cancellable keySelector and the comparer.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TKey">The type of the discriminator key computed for each element in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to retain distinct contiguous elements for, based on a computed key value.</param>
+        /// <param name="source">An async-enumerable sequence to retain distinct contiguous elements for, based on a computed key value.</param>
         /// <param name="keySelector">A function to compute the comparison key for each element asynchronously while supporting cancellation.</param>
         /// <param name="comparer">Equality comparer for computed key values.</param>
-        /// <returns>An observable sequence only containing the distinct contiguous elements, based on a computed key value, from the source sequence.</returns>
+        /// <returns>An async-enumerable sequence only containing the distinct contiguous elements, based on a computed key value, from the source sequence.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="keySelector"/> or <paramref name="comparer"/> is null.</exception>
         public static IAsyncEnumerable<TSource> DistinctUntilChanged<TSource, TKey>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<TKey>> keySelector, IEqualityComparer<TKey> comparer)
         {

+ 36 - 36
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Do.cs

@@ -13,12 +13,12 @@ namespace System.Linq
         // REVIEW: Should we convert Task-based overloads to ValueTask?
 
         /// <summary>
-        /// Invokes an action for each element in the observable sequence, and propagates all observer messages through the result sequence.
+        /// Invokes an action for each element in the async-enumerable sequence, and propagates all observer messages through the result sequence.
         /// This method can be used for debugging, logging, etc. of query behavior by intercepting the message stream to run arbitrary actions for messages on the pipeline.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <param name="source">Source sequence.</param>
-        /// <param name="onNext">Action to invoke for each element in the observable sequence.</param>
+        /// <param name="onNext">Action to invoke for each element in the async-enumerable sequence.</param>
         /// <returns>The source sequence with the side-effecting behavior applied.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="onNext"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Do<TSource>(this IAsyncEnumerable<TSource> source, Action<TSource> onNext)
@@ -32,13 +32,13 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Invokes an action for each element in the observable sequence and invokes an action upon graceful termination of the observable sequence.
+        /// Invokes an action for each element in the async-enumerable sequence and invokes an action upon graceful termination of the async-enumerable sequence.
         /// This method can be used for debugging, logging, etc. of query behavior by intercepting the message stream to run arbitrary actions for messages on the pipeline.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <param name="source">Source sequence.</param>
-        /// <param name="onNext">Action to invoke for each element in the observable sequence.</param>
-        /// <param name="onCompleted">Action to invoke upon graceful termination of the observable sequence.</param>
+        /// <param name="onNext">Action to invoke for each element in the async-enumerable sequence.</param>
+        /// <param name="onCompleted">Action to invoke upon graceful termination of the async-enumerable sequence.</param>
         /// <returns>The source sequence with the side-effecting behavior applied.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="onNext"/> or <paramref name="onCompleted"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Do<TSource>(this IAsyncEnumerable<TSource> source, Action<TSource> onNext, Action onCompleted)
@@ -54,13 +54,13 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Invokes an action for each element in the observable sequence and invokes an action upon exceptional termination of the observable sequence.
+        /// Invokes an action for each element in the async-enumerable sequence and invokes an action upon exceptional termination of the async-enumerable sequence.
         /// This method can be used for debugging, logging, etc. of query behavior by intercepting the message stream to run arbitrary actions for messages on the pipeline.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <param name="source">Source sequence.</param>
-        /// <param name="onNext">Action to invoke for each element in the observable sequence.</param>
-        /// <param name="onError">Action to invoke upon exceptional termination of the observable sequence.</param>
+        /// <param name="onNext">Action to invoke for each element in the async-enumerable sequence.</param>
+        /// <param name="onError">Action to invoke upon exceptional termination of the async-enumerable sequence.</param>
         /// <returns>The source sequence with the side-effecting behavior applied.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="onNext"/> or <paramref name="onError"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Do<TSource>(this IAsyncEnumerable<TSource> source, Action<TSource> onNext, Action<Exception> onError)
@@ -76,14 +76,14 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Invokes an action for each element in the observable sequence and invokes an action upon graceful or exceptional termination of the observable sequence.
+        /// Invokes an action for each element in the async-enumerable sequence and invokes an action upon graceful or exceptional termination of the async-enumerable sequence.
         /// This method can be used for debugging, logging, etc. of query behavior by intercepting the message stream to run arbitrary actions for messages on the pipeline.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <param name="source">Source sequence.</param>
-        /// <param name="onNext">Action to invoke for each element in the observable sequence.</param>
-        /// <param name="onError">Action to invoke upon exceptional termination of the observable sequence.</param>
-        /// <param name="onCompleted">Action to invoke upon graceful termination of the observable sequence.</param>
+        /// <param name="onNext">Action to invoke for each element in the async-enumerable sequence.</param>
+        /// <param name="onError">Action to invoke upon exceptional termination of the async-enumerable sequence.</param>
+        /// <param name="onCompleted">Action to invoke upon graceful termination of the async-enumerable sequence.</param>
         /// <returns>The source sequence with the side-effecting behavior applied.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="onNext"/> or <paramref name="onError"/> or <paramref name="onCompleted"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Do<TSource>(this IAsyncEnumerable<TSource> source, Action<TSource> onNext, Action<Exception> onError, Action onCompleted)
@@ -101,12 +101,12 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Invokes and awaits an asynchronous action for each element in the observable sequence, and propagates all observer messages through the result sequence.
+        /// Invokes and awaits an asynchronous action for each element in the async-enumerable sequence, and propagates all observer messages through the result sequence.
         /// This method can be used for debugging, logging, etc. of query behavior by intercepting the message stream to run arbitrary actions for messages on the pipeline.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <param name="source">Source sequence.</param>
-        /// <param name="onNext">Action to invoke and await for each element in the observable sequence.</param>
+        /// <param name="onNext">Action to invoke and await for each element in the async-enumerable sequence.</param>
         /// <returns>The source sequence with the side-effecting behavior applied.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="onNext"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Do<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task> onNext)
@@ -120,13 +120,13 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Invokes and awaits an asynchronous action for each element in the observable sequence, then invokes and awaits an asynchronous an action upon graceful termination of the observable sequence.
+        /// Invokes and awaits an asynchronous action for each element in the async-enumerable sequence, then invokes and awaits an asynchronous an action upon graceful termination of the async-enumerable sequence.
         /// This method can be used for debugging, logging, etc. of query behavior by intercepting the message stream to run arbitrary actions for messages on the pipeline.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <param name="source">Source sequence.</param>
-        /// <param name="onNext">Action to invoke and await for each element in the observable sequence.</param>
-        /// <param name="onCompleted">Action to invoke and await upon graceful termination of the observable sequence.</param>
+        /// <param name="onNext">Action to invoke and await for each element in the async-enumerable sequence.</param>
+        /// <param name="onCompleted">Action to invoke and await upon graceful termination of the async-enumerable sequence.</param>
         /// <returns>The source sequence with the side-effecting behavior applied.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="onNext"/> or <paramref name="onCompleted"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Do<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task> onNext, Func<Task> onCompleted)
@@ -142,13 +142,13 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Invokes and awaits an asynchronous action for each element in the observable sequence, then invokes and awaits an asynchronous action upon exceptional termination of the observable sequence.
+        /// Invokes and awaits an asynchronous action for each element in the async-enumerable sequence, then invokes and awaits an asynchronous action upon exceptional termination of the async-enumerable sequence.
         /// This method can be used for debugging, logging, etc. of query behavior by intercepting the message stream to run arbitrary actions for messages on the pipeline.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <param name="source">Source sequence.</param>
-        /// <param name="onNext">Action to invoke and await for each element in the observable sequence.</param>
-        /// <param name="onError">Action to invoke and await upon exceptional termination of the observable sequence.</param>
+        /// <param name="onNext">Action to invoke and await for each element in the async-enumerable sequence.</param>
+        /// <param name="onError">Action to invoke and await upon exceptional termination of the async-enumerable sequence.</param>
         /// <returns>The source sequence with the side-effecting behavior applied.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="onNext"/> or <paramref name="onError"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Do<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task> onNext, Func<Exception, Task> onError)
@@ -164,14 +164,14 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Invokes and awaits an asynchronous action for each element in the observable sequence, then invokes and awaits an asynchronous action upon graceful or exceptional termination of the observable sequence.
+        /// Invokes and awaits an asynchronous action for each element in the async-enumerable sequence, then invokes and awaits an asynchronous action upon graceful or exceptional termination of the async-enumerable sequence.
         /// This method can be used for debugging, logging, etc. of query behavior by intercepting the message stream to run arbitrary actions for messages on the pipeline.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <param name="source">Source sequence.</param>
-        /// <param name="onNext">Action to invoke and await for each element in the observable sequence.</param>
-        /// <param name="onError">Action to invoke and await upon exceptional termination of the observable sequence.</param>
-        /// <param name="onCompleted">Action to invoke and await upon graceful termination of the observable sequence.</param>
+        /// <param name="onNext">Action to invoke and await for each element in the async-enumerable sequence.</param>
+        /// <param name="onError">Action to invoke and await upon exceptional termination of the async-enumerable sequence.</param>
+        /// <param name="onCompleted">Action to invoke and await upon graceful termination of the async-enumerable sequence.</param>
         /// <returns>The source sequence with the side-effecting behavior applied.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="onNext"/> or <paramref name="onError"/> or <paramref name="onCompleted"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Do<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, Task> onNext, Func<Exception, Task> onError, Func<Task> onCompleted)
@@ -190,12 +190,12 @@ namespace System.Linq
 
 #if !NO_DEEP_CANCELLATION
         /// <summary>
-        /// Invokes and awaits an asynchronous (cancellable) action for each element in the observable sequence, and propagates all observer messages through the result sequence.
+        /// Invokes and awaits an asynchronous (cancellable) action for each element in the async-enumerable sequence, and propagates all observer messages through the result sequence.
         /// This method can be used for debugging, logging, etc. of query behavior by intercepting the message stream to run arbitrary actions for messages on the pipeline.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <param name="source">Source sequence.</param>
-        /// <param name="onNext">Action to invoke and await for each element in the observable sequence while supporting cancellation.</param>
+        /// <param name="onNext">Action to invoke and await for each element in the async-enumerable sequence while supporting cancellation.</param>
         /// <returns>The source sequence with the side-effecting behavior applied.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="onNext"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Do<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, Task> onNext)
@@ -209,13 +209,13 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Invokes and awaits an asynchronous (cancellable) action for each element in the observable sequence, then invokes and awaits an asynchronous (cancellable) an action upon graceful termination of the observable sequence.
+        /// Invokes and awaits an asynchronous (cancellable) action for each element in the async-enumerable sequence, then invokes and awaits an asynchronous (cancellable) an action upon graceful termination of the async-enumerable sequence.
         /// This method can be used for debugging, logging, etc. of query behavior by intercepting the message stream to run arbitrary actions for messages on the pipeline.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <param name="source">Source sequence.</param>
-        /// <param name="onNext">Action to invoke and await for each element in the observable sequence while supporting cancellation.</param>
-        /// <param name="onCompleted">Action to invoke and await upon graceful termination of the observable sequence while supporting cancellation.</param>
+        /// <param name="onNext">Action to invoke and await for each element in the async-enumerable sequence while supporting cancellation.</param>
+        /// <param name="onCompleted">Action to invoke and await upon graceful termination of the async-enumerable sequence while supporting cancellation.</param>
         /// <returns>The source sequence with the side-effecting behavior applied.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="onNext"/> or <paramref name="onCompleted"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Do<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, Task> onNext, Func<CancellationToken, Task> onCompleted)
@@ -231,13 +231,13 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Invokes and awaits an asynchronous (cancellable) action for each element in the observable sequence, then invokes and awaits an asynchronous (cancellable) action upon exceptional termination of the observable sequence.
+        /// Invokes and awaits an asynchronous (cancellable) action for each element in the async-enumerable sequence, then invokes and awaits an asynchronous (cancellable) action upon exceptional termination of the async-enumerable sequence.
         /// This method can be used for debugging, logging, etc. of query behavior by intercepting the message stream to run arbitrary actions for messages on the pipeline.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <param name="source">Source sequence.</param>
-        /// <param name="onNext">Action to invoke and await for each element in the observable sequence while supporting cancellation.</param>
-        /// <param name="onError">Action to invoke and await upon exceptional termination of the observable sequence while supporting cancellation.</param>
+        /// <param name="onNext">Action to invoke and await for each element in the async-enumerable sequence while supporting cancellation.</param>
+        /// <param name="onError">Action to invoke and await upon exceptional termination of the async-enumerable sequence while supporting cancellation.</param>
         /// <returns>The source sequence with the side-effecting behavior applied.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="onNext"/> or <paramref name="onError"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Do<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, Task> onNext, Func<Exception, CancellationToken, Task> onError)
@@ -253,14 +253,14 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Invokes and awaits an asynchronous (cancellable) action for each element in the observable sequence, then invokes and awaits an asynchronous (cancellable) action upon graceful or exceptional termination of the observable sequence.
+        /// Invokes and awaits an asynchronous (cancellable) action for each element in the async-enumerable sequence, then invokes and awaits an asynchronous (cancellable) action upon graceful or exceptional termination of the async-enumerable sequence.
         /// This method can be used for debugging, logging, etc. of query behavior by intercepting the message stream to run arbitrary actions for messages on the pipeline.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <param name="source">Source sequence.</param>
-        /// <param name="onNext">Action to invoke and await for each element in the observable sequence while supporting cancellation.</param>
-        /// <param name="onError">Action to invoke and await upon exceptional termination of the observable sequence while supporting cancellation.</param>
-        /// <param name="onCompleted">Action to invoke and await upon graceful termination of the observable sequence while supporting cancellation.</param>
+        /// <param name="onNext">Action to invoke and await for each element in the async-enumerable sequence while supporting cancellation.</param>
+        /// <param name="onError">Action to invoke and await upon exceptional termination of the async-enumerable sequence while supporting cancellation.</param>
+        /// <param name="onCompleted">Action to invoke and await upon graceful termination of the async-enumerable sequence while supporting cancellation.</param>
         /// <returns>The source sequence with the side-effecting behavior applied.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="onNext"/> or <paramref name="onError"/> or <paramref name="onCompleted"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Do<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, Task> onNext, Func<Exception, CancellationToken, Task> onError, Func<CancellationToken, Task> onCompleted)

+ 4 - 4
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Finally.cs

@@ -11,11 +11,11 @@ namespace System.Linq
     public static partial class AsyncEnumerableEx
     {
         /// <summary>
-        /// Invokes a specified action after the source observable sequence terminates gracefully or exceptionally.
+        /// Invokes a specified action after the source async-enumerable sequence terminates gracefully or exceptionally.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <param name="source">Source sequence.</param>
-        /// <param name="finallyAction">Action to invoke after the source observable sequence terminates.</param>
+        /// <param name="finallyAction">Action to invoke after the source async-enumerable sequence terminates.</param>
         /// <returns>Source sequence with the action-invoking termination behavior applied.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="finallyAction"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Finally<TSource>(this IAsyncEnumerable<TSource> source, Action finallyAction)
@@ -44,11 +44,11 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Invokes a specified asynchronous action after the source observable sequence terminates gracefully or exceptionally.
+        /// Invokes a specified asynchronous action after the source async-enumerable sequence terminates gracefully or exceptionally.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <param name="source">Source sequence.</param>
-        /// <param name="finallyAction">Action to invoke and await asynchronously after the source observable sequence terminates.</param>
+        /// <param name="finallyAction">Action to invoke and await asynchronously after the source async-enumerable sequence terminates.</param>
         /// <returns>Source sequence with the action-invoking termination behavior applied.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="finallyAction"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Finally<TSource>(this IAsyncEnumerable<TSource> source, Func<Task> finallyAction)

+ 1 - 1
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Generate.cs

@@ -12,7 +12,7 @@ namespace System.Linq
         // REVIEW: Add async variant?
 
         /// <summary>
-        /// Generates an observable sequence by running a state-driven loop producing the sequence's elements.
+        /// Generates an async-enumerable sequence by running a state-driven loop producing the sequence's elements.
         /// </summary>
         /// <typeparam name="TState">The type of the state used in the generator loop.</typeparam>
         /// <typeparam name="TResult">The type of the elements in the produced sequence.</typeparam>

+ 2 - 2
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/IgnoreElements.cs

@@ -11,11 +11,11 @@ namespace System.Linq
     public static partial class AsyncEnumerableEx
     {
         /// <summary>
-        /// Ignores all elements in an observable sequence leaving only the termination messages.
+        /// Ignores all elements in an async-enumerable sequence leaving only the termination messages.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <param name="source">Source sequence.</param>
-        /// <returns>An empty observable sequence that signals termination, successful or exceptional, of the source sequence.</returns>
+        /// <returns>An empty async-enumerable sequence that signals termination, successful or exceptional, of the source sequence.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> is null.</exception>
         public static IAsyncEnumerable<TSource> IgnoreElements<TSource>(this IAsyncEnumerable<TSource> source)
         {

+ 3 - 3
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/IsEmpty.cs

@@ -11,12 +11,12 @@ namespace System.Linq
     public static partial class AsyncEnumerableEx
     {
         /// <summary>
-        /// Determines whether an observable sequence is empty.
+        /// Determines whether an async-enumerable sequence is empty.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to check for emptiness.</param>
+        /// <param name="source">An async-enumerable sequence to check for emptiness.</param>
         /// <param name="cancellationToken">The optional cancellation token to be used for cancelling the sequence at any time.</param>
-        /// <returns>An observable sequence containing a single element determining whether the source sequence is empty.</returns>
+        /// <returns>An async-enumerable sequence containing a single element determining whether the source sequence is empty.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> is null.</exception>
         public static ValueTask<bool> IsEmptyAsync<TSource>(this IAsyncEnumerable<TSource> source, CancellationToken cancellationToken = default)
         {

+ 3 - 3
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Max.cs

@@ -11,13 +11,13 @@ namespace System.Linq
     public static partial class AsyncEnumerableEx
     {
         /// <summary>
-        /// Returns the maximum value in an observable sequence according to the specified comparer.
+        /// Returns the maximum value in an async-enumerable sequence according to the specified comparer.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to determine the maximum element of.</param>
+        /// <param name="source">An async-enumerable sequence to determine the maximum element of.</param>
         /// <param name="comparer">Comparer used to compare elements.</param>
         /// <param name="cancellationToken">The optional cancellation token to be used for cancelling the sequence at any time.</param>
-        /// <returns>An observable sequence containing a single element with the maximum element in the source sequence.</returns>
+        /// <returns>An async-enumerable sequence containing a single element with the maximum element in the source sequence.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="comparer"/> is null.</exception>
         /// <remarks>The return type of this operator differs from the corresponding operator on IEnumerable in order to retain asynchronous behavior.</remarks>
         public static ValueTask<TSource> MaxAsync<TSource>(this IAsyncEnumerable<TSource> source, IComparer<TSource>? comparer, CancellationToken cancellationToken = default)

+ 12 - 12
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/MaxBy.cs

@@ -11,11 +11,11 @@ namespace System.Linq
     public static partial class AsyncEnumerableEx
     {
         /// <summary>
-        /// Returns the elements in an observable sequence with the maximum key value.
+        /// Returns the elements in an async-enumerable sequence with the maximum key value.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TKey">The type of the key computed for each element in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to get the maximum elements for.</param>
+        /// <param name="source">An async-enumerable sequence to get the maximum elements for.</param>
         /// <param name="keySelector">Key selector function.</param>
         /// <param name="cancellationToken">The optional cancellation token to be used for cancelling the sequence at any time.</param>
         /// <returns>A ValueTask containing a list of zero or more elements that have a maximum key value.</returns>
@@ -32,11 +32,11 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Returns the elements in an observable sequence with the maximum key value according to the specified comparer.
+        /// Returns the elements in an async-enumerable sequence with the maximum key value according to the specified comparer.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TKey">The type of the key computed for each element in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to get the maximum elements for.</param>
+        /// <param name="source">An async-enumerable sequence to get the maximum elements for.</param>
         /// <param name="keySelector">Key selector function.</param>
         /// <param name="comparer">Comparer used to compare key values.</param>
         /// <param name="cancellationToken">The optional cancellation token to be used for cancelling the sequence at any time.</param>
@@ -54,11 +54,11 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Returns the elements in an observable sequence with the maximum key value.
+        /// Returns the elements in an async-enumerable sequence with the maximum key value.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TKey">The type of the key computed for each element in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to get the maximum elements for.</param>
+        /// <param name="source">An async-enumerable sequence to get the maximum elements for.</param>
         /// <param name="keySelector">Key selector function returning a key possibly asynchronously.</param>
         /// <param name="cancellationToken">The optional cancellation token to be used for cancelling the sequence at any time.</param>
         /// <returns>A ValueTask containing a list of zero or more elements that have a maximum key value.</returns>
@@ -76,11 +76,11 @@ namespace System.Linq
 
 #if !NO_DEEP_CANCELLATION
         /// <summary>
-        /// Returns the elements in an observable sequence with the maximum key value.
+        /// Returns the elements in an async-enumerable sequence with the maximum key value.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TKey">The type of the key computed for each element in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to get the maximum elements for.</param>
+        /// <param name="source">An async-enumerable sequence to get the maximum elements for.</param>
         /// <param name="keySelector">Key selector function returning a key possibly asynchronously and supporting cancellation.</param>
         /// <param name="cancellationToken">The optional cancellation token to be used for cancelling the sequence at any time.</param>
         /// <returns>A ValueTask containing a list of zero or more elements that have a maximum key value.</returns>
@@ -98,11 +98,11 @@ namespace System.Linq
 #endif
 
         /// <summary>
-        /// Returns the elements in an observable sequence with the maximum key value according to the specified comparer.
+        /// Returns the elements in an async-enumerable sequence with the maximum key value according to the specified comparer.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TKey">The type of the key computed for each element in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to get the maximum elements for.</param>
+        /// <param name="source">An async-enumerable sequence to get the maximum elements for.</param>
         /// <param name="keySelector">Key selector function returning a key possibly asynchronously.</param>
         /// <param name="comparer">Comparer used to compare key values.</param>
         /// <param name="cancellationToken">The optional cancellation token to be used for cancelling the sequence at any time.</param>
@@ -121,11 +121,11 @@ namespace System.Linq
 
 #if !NO_DEEP_CANCELLATION
         /// <summary>
-        /// Returns the elements in an observable sequence with the maximum key value according to the specified comparer.
+        /// Returns the elements in an async-enumerable sequence with the maximum key value according to the specified comparer.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TKey">The type of the key computed for each element in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to get the maximum elements for.</param>
+        /// <param name="source">An async-enumerable sequence to get the maximum elements for.</param>
         /// <param name="keySelector">Key selector function returning a key possibly asynchronously and supporting cancellation.</param>
         /// <param name="comparer">Comparer used to compare key values.</param>
         /// <param name="cancellationToken">The optional cancellation token to be used for cancelling the sequence at any time.</param>

+ 8 - 8
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Merge.cs

@@ -11,11 +11,11 @@ namespace System.Linq
     public static partial class AsyncEnumerableEx
     {
         /// <summary>
-        /// Merges elements from all of the specified observable sequences into a single observable sequence.
+        /// Merges elements from all of the specified async-enumerable sequences into a single async-enumerable sequence.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequences.</typeparam>
         /// <param name="sources">Observable sequences.</param>
-        /// <returns>The observable sequence that merges the elements of the observable sequences.</returns>
+        /// <returns>The async-enumerable sequence that merges the elements of the async-enumerable sequences.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="sources"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Merge<TSource>(params IAsyncEnumerable<TSource>[] sources)
         {
@@ -304,11 +304,11 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Merges elements from all observable sequences in the given enumerable sequence into a single observable sequence.
+        /// Merges elements from all async-enumerable sequences in the given enumerable sequence into a single async-enumerable sequence.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequences.</typeparam>
-        /// <param name="sources">Enumerable sequence of observable sequences.</param>
-        /// <returns>The observable sequence that merges the elements of the observable sequences.</returns>
+        /// <param name="sources">Enumerable sequence of async-enumerable sequences.</param>
+        /// <returns>The async-enumerable sequence that merges the elements of the async-enumerable sequences.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="sources"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Merge<TSource>(this IEnumerable<IAsyncEnumerable<TSource>> sources)
         {
@@ -338,11 +338,11 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Merges elements from all inner observable sequences into a single observable sequence.
+        /// Merges elements from all inner async-enumerable sequences into a single async-enumerable sequence.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequences.</typeparam>
-        /// <param name="sources">Observable sequence of inner observable sequences.</param>
-        /// <returns>The observable sequence that merges the elements of the inner sequences.</returns>
+        /// <param name="sources">Observable sequence of inner async-enumerable sequences.</param>
+        /// <returns>The async-enumerable sequence that merges the elements of the inner sequences.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="sources"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Merge<TSource>(this IAsyncEnumerable<IAsyncEnumerable<TSource>> sources)
         {

+ 3 - 3
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Min.cs

@@ -11,13 +11,13 @@ namespace System.Linq
     public static partial class AsyncEnumerableEx
     {
         /// <summary>
-        /// Returns the minimum element in an observable sequence according to the specified comparer.
+        /// Returns the minimum element in an async-enumerable sequence according to the specified comparer.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to determine the minimum element of.</param>
+        /// <param name="source">An async-enumerable sequence to determine the minimum element of.</param>
         /// <param name="comparer">Comparer used to compare elements.</param>
         /// <param name="cancellationToken">The optional cancellation token to be used for cancelling the sequence at any time.</param>
-        /// <returns>An observable sequence containing a single element with the minimum element in the source sequence.</returns>
+        /// <returns>An async-enumerable sequence containing a single element with the minimum element in the source sequence.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="comparer"/> is null.</exception>
         /// <remarks>The return type of this operator differs from the corresponding operator on IEnumerable in order to retain asynchronous behavior.</remarks>
         public static ValueTask<TSource> MinAsync<TSource>(this IAsyncEnumerable<TSource> source, IComparer<TSource>? comparer, CancellationToken cancellationToken = default)

+ 12 - 12
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/MinBy.cs

@@ -11,11 +11,11 @@ namespace System.Linq
     public static partial class AsyncEnumerableEx
     {
         /// <summary>
-        /// Returns the elements in an observable sequence with the minimum key value.
+        /// Returns the elements in an async-enumerable sequence with the minimum key value.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TKey">The type of the key computed for each element in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to get the minimum elements for.</param>
+        /// <param name="source">An async-enumerable sequence to get the minimum elements for.</param>
         /// <param name="keySelector">Key selector function.</param>
         /// <param name="cancellationToken">The optional cancellation token to be used for cancelling the sequence at any time.</param>
         /// <returns>A ValueTask containing a list of zero or more elements that have a minimum key value.</returns>
@@ -32,11 +32,11 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Returns the elements in an observable sequence with the minimum key value according to the specified comparer.
+        /// Returns the elements in an async-enumerable sequence with the minimum key value according to the specified comparer.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TKey">The type of the key computed for each element in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to get the minimum elements for.</param>
+        /// <param name="source">An async-enumerable sequence to get the minimum elements for.</param>
         /// <param name="keySelector">Key selector function.</param>
         /// <param name="comparer">Comparer used to compare key values.</param>
         /// <param name="cancellationToken">The optional cancellation token to be used for cancelling the sequence at any time.</param>
@@ -54,11 +54,11 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Returns the elements in an observable sequence with the minimum key value.
+        /// Returns the elements in an async-enumerable sequence with the minimum key value.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TKey">The type of the key computed for each element in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to get the minimum elements for.</param>
+        /// <param name="source">An async-enumerable sequence to get the minimum elements for.</param>
         /// <param name="keySelector">Key selector function returning a key possibly asynchronously.</param>
         /// <param name="cancellationToken">The optional cancellation token to be used for cancelling the sequence at any time.</param>
         /// <returns>A ValueTask containing a list of zero or more elements that have a minimum key value.</returns>
@@ -76,11 +76,11 @@ namespace System.Linq
 
 #if !NO_DEEP_CANCELLATION
         /// <summary>
-        /// Returns the elements in an observable sequence with the minimum key value.
+        /// Returns the elements in an async-enumerable sequence with the minimum key value.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TKey">The type of the key computed for each element in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to get the minimum elements for.</param>
+        /// <param name="source">An async-enumerable sequence to get the minimum elements for.</param>
         /// <param name="keySelector">Key selector function returning a key possibly asynchronously and supporting cancellation.</param>
         /// <param name="cancellationToken">The optional cancellation token to be used for cancelling the sequence at any time.</param>
         /// <returns>A ValueTask containing a list of zero or more elements that have a minimum key value.</returns>
@@ -98,11 +98,11 @@ namespace System.Linq
 #endif
 
         /// <summary>
-        /// Returns the elements in an observable sequence with the minimum key value according to the specified comparer.
+        /// Returns the elements in an async-enumerable sequence with the minimum key value according to the specified comparer.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TKey">The type of the key computed for each element in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to get the minimum elements for.</param>
+        /// <param name="source">An async-enumerable sequence to get the minimum elements for.</param>
         /// <param name="keySelector">Key selector function returning a key possibly asynchronously.</param>
         /// <param name="comparer">Comparer used to compare key values.</param>
         /// <param name="cancellationToken">The optional cancellation token to be used for cancelling the sequence at any time.</param>
@@ -121,11 +121,11 @@ namespace System.Linq
 
 #if !NO_DEEP_CANCELLATION
         /// <summary>
-        /// Returns the elements in an observable sequence with the minimum key value according to the specified comparer.
+        /// Returns the elements in an async-enumerable sequence with the minimum key value according to the specified comparer.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TKey">The type of the key computed for each element in the source sequence.</typeparam>
-        /// <param name="source">An observable sequence to get the minimum elements for.</param>
+        /// <param name="source">An async-enumerable sequence to get the minimum elements for.</param>
         /// <param name="keySelector">Key selector function returning a key possibly asynchronously and supporting cancellation.</param>
         /// <param name="comparer">Comparer used to compare key values.</param>
         /// <param name="cancellationToken">The optional cancellation token to be used for cancelling the sequence at any time.</param>

+ 2 - 2
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Never.cs

@@ -11,10 +11,10 @@ namespace System.Linq
     public static partial class AsyncEnumerableEx
     {
         /// <summary>
-        /// Returns a non-terminating observable sequence, which can be used to denote an infinite duration (e.g. when using reactive joins).
+        /// Returns a non-terminating async-enumerable sequence, which can be used to denote an infinite duration (e.g. when using reactive joins).
         /// </summary>
         /// <typeparam name="TValue">The type used for the <see cref="IAsyncEnumerable{T}"/> type parameter of the resulting sequence.</typeparam>
-        /// <returns>An observable sequence whose consumers will never resume after awaiting <see cref="IAsyncEnumerator{T}.MoveNextAsync"/>.</returns>
+        /// <returns>An async-enumerable sequence whose consumers will never resume after awaiting <see cref="IAsyncEnumerator{T}.MoveNextAsync"/>.</returns>
         public static IAsyncEnumerable<TValue> Never<TValue>() => NeverAsyncEnumerable<TValue>.Instance;
 
         private sealed class NeverAsyncEnumerable<TValue> : IAsyncEnumerable<TValue>

+ 8 - 8
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/OnErrorResumeNext.cs

@@ -10,12 +10,12 @@ namespace System.Linq
     public static partial class AsyncEnumerableEx
     {
         /// <summary>
-        /// Concatenates the second observable sequence to the first observable sequence upon successful or exceptional termination of the first.
+        /// Concatenates the second async-enumerable sequence to the first async-enumerable sequence upon successful or exceptional termination of the first.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequences.</typeparam>
-        /// <param name="first">First observable sequence whose exception (if any) is caught.</param>
-        /// <param name="second">Second observable sequence used to produce results after the first sequence terminates.</param>
-        /// <returns>An observable sequence that concatenates the first and second sequence, even if the first sequence terminates exceptionally.</returns>
+        /// <param name="first">First async-enumerable sequence whose exception (if any) is caught.</param>
+        /// <param name="second">Second async-enumerable sequence used to produce results after the first sequence terminates.</param>
+        /// <returns>An async-enumerable sequence that concatenates the first and second sequence, even if the first sequence terminates exceptionally.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="first"/> or <paramref name="second"/> is null.</exception>
         public static IAsyncEnumerable<TSource> OnErrorResumeNext<TSource>(this IAsyncEnumerable<TSource> first, IAsyncEnumerable<TSource> second)
         {
@@ -28,11 +28,11 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Concatenates all of the specified observable sequences, even if the previous observable sequence terminated exceptionally.
+        /// Concatenates all of the specified async-enumerable sequences, even if the previous async-enumerable sequence terminated exceptionally.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequences.</typeparam>
         /// <param name="sources">Observable sequences to concatenate.</param>
-        /// <returns>An observable sequence that concatenates the source sequences, even if a sequence terminates exceptionally.</returns>
+        /// <returns>An async-enumerable sequence that concatenates the source sequences, even if a sequence terminates exceptionally.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="sources"/> is null.</exception>
         public static IAsyncEnumerable<TSource> OnErrorResumeNext<TSource>(params IAsyncEnumerable<TSource>[] sources)
         {
@@ -43,11 +43,11 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Concatenates all observable sequences in the given enumerable sequence, even if the previous observable sequence terminated exceptionally.
+        /// Concatenates all async-enumerable sequences in the given enumerable sequence, even if the previous async-enumerable sequence terminated exceptionally.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequences.</typeparam>
         /// <param name="sources">Observable sequences to concatenate.</param>
-        /// <returns>An observable sequence that concatenates the source sequences, even if a sequence terminates exceptionally.</returns>
+        /// <returns>An async-enumerable sequence that concatenates the source sequences, even if a sequence terminates exceptionally.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="sources"/> is null.</exception>
         public static IAsyncEnumerable<TSource> OnErrorResumeNext<TSource>(this IEnumerable<IAsyncEnumerable<TSource>> sources)
         {

+ 7 - 7
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Repeat.cs

@@ -15,7 +15,7 @@ namespace System.Linq
         /// </summary>
         /// <typeparam name="TResult">The type of the elements in the source sequence.</typeparam>
         /// <param name="element">Element to repeat.</param>
-        /// <returns>The observable sequence producing the element repeatedly and sequentially.</returns>
+        /// <returns>The async-enumerable sequence producing the element repeatedly and sequentially.</returns>
         public static IAsyncEnumerable<TResult> Repeat<TResult>(TResult element)
         {
             return AsyncEnumerable.Create(Core);
@@ -34,11 +34,11 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Repeats the observable sequence indefinitely.
+        /// Repeats the async-enumerable sequence indefinitely.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <param name="source">Observable sequence to repeat.</param>
-        /// <returns>The observable sequence producing the elements of the given sequence repeatedly and sequentially.</returns>
+        /// <returns>The async-enumerable sequence producing the elements of the given sequence repeatedly and sequentially.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Repeat<TSource>(this IAsyncEnumerable<TSource> source)
         {
@@ -60,14 +60,14 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Repeats the observable sequence a specified number of times.
+        /// Repeats the async-enumerable sequence a specified number of times.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <param name="source">Observable sequence to repeat.</param>
-        /// <param name="repeatCount">Number of times to repeat the sequence.</param>
-        /// <returns>The observable sequence producing the elements of the given sequence repeatedly.</returns>
+        /// <param name="count">Number of times to repeat the sequence.</param>
+        /// <returns>The async-enumerable sequence producing the elements of the given sequence repeatedly.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> is null.</exception>
-        /// <exception cref="ArgumentOutOfRangeException"><paramref name="repeatCount"/> is less than zero.</exception>
+        /// <exception cref="ArgumentOutOfRangeException"><paramref name="count"/> is less than zero.</exception>
         public static IAsyncEnumerable<TSource> Repeat<TSource>(this IAsyncEnumerable<TSource> source, int count)
         {
             if (source == null)

+ 4 - 4
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Retry.cs

@@ -9,11 +9,11 @@ namespace System.Linq
     public static partial class AsyncEnumerableEx
     {
         /// <summary>
-        /// Repeats the source observable sequence until it successfully terminates.
+        /// Repeats the source async-enumerable sequence until it successfully terminates.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <param name="source">Observable sequence to repeat until it successfully terminates.</param>
-        /// <returns>An observable sequence producing the elements of the given sequence repeatedly until it terminates successfully.</returns>
+        /// <returns>An async-enumerable sequence producing the elements of the given sequence repeatedly until it terminates successfully.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Retry<TSource>(this IAsyncEnumerable<TSource> source)
         {
@@ -24,12 +24,12 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Repeats the source observable sequence the specified number of times or until it successfully terminates.
+        /// Repeats the source async-enumerable sequence the specified number of times or until it successfully terminates.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <param name="source">Observable sequence to repeat until it successfully terminates.</param>
         /// <param name="retryCount">Number of times to repeat the sequence.</param>
-        /// <returns>An observable sequence producing the elements of the given sequence repeatedly until it terminates successfully.</returns>
+        /// <returns>An async-enumerable sequence producing the elements of the given sequence repeatedly until it terminates successfully.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> is null.</exception>
         /// <exception cref="ArgumentOutOfRangeException"><paramref name="retryCount"/> is less than zero.</exception>
         public static IAsyncEnumerable<TSource> Retry<TSource>(this IAsyncEnumerable<TSource> source, int retryCount)

+ 3 - 3
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Return.cs

@@ -11,11 +11,11 @@ namespace System.Linq
     public static partial class AsyncEnumerableEx
     {
         /// <summary>
-        /// Returns an observable sequence that contains a single element.
+        /// Returns an async-enumerable sequence that contains a single element.
         /// </summary>
         /// <typeparam name="TValue">The type of the element that will be returned in the produced sequence.</typeparam>
-        /// <param name="value">Single element in the resulting observable sequence.</param>
-        /// <returns>An observable sequence containing the single specified element.</returns>
+        /// <param name="value">Single element in the resulting async-enumerable sequence.</param>
+        /// <returns>An async-enumerable sequence containing the single specified element.</returns>
         public static IAsyncEnumerable<TValue> Return<TValue>(TValue value) => new ReturnEnumerable<TValue>(value);
 
         // REVIEW: Add support for IAsyncPartition<T>.

+ 18 - 18
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Scan.cs

@@ -15,13 +15,13 @@ namespace System.Linq
         //     but one could argue whether it was the right default.
 
         /// <summary>
-        /// Applies an accumulator function over an observable sequence and returns each intermediate result.
+        /// Applies an accumulator function over an async-enumerable sequence and returns each intermediate result.
         /// For aggregation behavior with no intermediate results, see <see cref="AsyncEnumerable.AggregateAsync{TSource}"/>.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence and the result of the aggregation.</typeparam>
-        /// <param name="source">An observable sequence to accumulate over.</param>
+        /// <param name="source">An async-enumerable sequence to accumulate over.</param>
         /// <param name="accumulator">An accumulator function to be invoked on each element.</param>
-        /// <returns>An observable sequence containing the accumulated values.</returns>
+        /// <returns>An async-enumerable sequence containing the accumulated values.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="accumulator"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Scan<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, TSource, TSource> accumulator)
         {
@@ -53,15 +53,15 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Applies an accumulator function over an observable sequence and returns each intermediate result. The specified seed value is used as the initial accumulator value.
+        /// Applies an accumulator function over an async-enumerable sequence and returns each intermediate result. The specified seed value is used as the initial accumulator value.
         /// For aggregation behavior with no intermediate results, see <see cref="AsyncEnumerable.AggregateAsync{TSource, Accumulate}"/>.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TAccumulate">The type of the result of the aggregation.</typeparam>
-        /// <param name="source">An observable sequence to accumulate over.</param>
+        /// <param name="source">An async-enumerable sequence to accumulate over.</param>
         /// <param name="seed">The initial accumulator value.</param>
         /// <param name="accumulator">An accumulator function to be invoked on each element.</param>
-        /// <returns>An observable sequence containing the accumulated values.</returns>
+        /// <returns>An async-enumerable sequence containing the accumulated values.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="accumulator"/> is null.</exception>
         public static IAsyncEnumerable<TAccumulate> Scan<TSource, TAccumulate>(this IAsyncEnumerable<TSource> source, TAccumulate seed, Func<TAccumulate, TSource, TAccumulate> accumulator)
         {
@@ -86,13 +86,13 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Applies an asynchronous accumulator function over an observable sequence and returns each intermediate result.
+        /// Applies an asynchronous accumulator function over an async-enumerable sequence and returns each intermediate result.
         /// For aggregation behavior with no intermediate results, see <see cref="AsyncEnumerable.AggregateAsync{TSource}"/>.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence and the result of the aggregation.</typeparam>
-        /// <param name="source">An observable sequence to accumulate over.</param>
+        /// <param name="source">An async-enumerable sequence to accumulate over.</param>
         /// <param name="accumulator">An asynchronous accumulator function to be invoked and awaited on each element.</param>
-        /// <returns>An observable sequence containing the accumulated values.</returns>
+        /// <returns>An async-enumerable sequence containing the accumulated values.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="accumulator"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Scan<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, TSource, ValueTask<TSource>> accumulator)
         {
@@ -125,13 +125,13 @@ namespace System.Linq
 
 #if !NO_DEEP_CANCELLATION
         /// <summary>
-        /// Applies an asynchronous (cancellable) accumulator function over an observable sequence and returns each intermediate result.
+        /// Applies an asynchronous (cancellable) accumulator function over an async-enumerable sequence and returns each intermediate result.
         /// For aggregation behavior with no intermediate results, see <see cref="AsyncEnumerable.AggregateAsync{TSource}"/>.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence and the result of the aggregation.</typeparam>
-        /// <param name="source">An observable sequence to accumulate over.</param>
+        /// <param name="source">An async-enumerable sequence to accumulate over.</param>
         /// <param name="accumulator">An asynchronous (cancellable) accumulator function to be invoked and awaited on each element.</param>
-        /// <returns>An observable sequence containing the accumulated values.</returns>
+        /// <returns>An async-enumerable sequence containing the accumulated values.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="accumulator"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Scan<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, TSource, CancellationToken, ValueTask<TSource>> accumulator)
         {
@@ -164,15 +164,15 @@ namespace System.Linq
 #endif
 
         /// <summary>
-        /// Applies an asynchronous accumulator function over an observable sequence and returns each intermediate result. The specified seed value is used as the initial accumulator value.
+        /// Applies an asynchronous accumulator function over an async-enumerable sequence and returns each intermediate result. The specified seed value is used as the initial accumulator value.
         /// For aggregation behavior with no intermediate results, see <see cref="AsyncEnumerable.AggregateAsync{TSource, Accumulate}"/>.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TAccumulate">The type of the result of the aggregation.</typeparam>
-        /// <param name="source">An observable sequence to accumulate over.</param>
+        /// <param name="source">An async-enumerable sequence to accumulate over.</param>
         /// <param name="seed">The initial accumulator value.</param>
         /// <param name="accumulator">An asynchronous accumulator function to be invoked on each element.</param>
-        /// <returns>An observable sequence containing the accumulated values.</returns>
+        /// <returns>An async-enumerable sequence containing the accumulated values.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="accumulator"/> is null.</exception>
         public static IAsyncEnumerable<TAccumulate> Scan<TSource, TAccumulate>(this IAsyncEnumerable<TSource> source, TAccumulate seed, Func<TAccumulate, TSource, ValueTask<TAccumulate>> accumulator)
         {
@@ -198,15 +198,15 @@ namespace System.Linq
 
 #if !NO_DEEP_CANCELLATION
         /// <summary>
-        /// Applies an asynchronous (cancellable) accumulator function over an observable sequence and returns each intermediate result. The specified seed value is used as the initial accumulator value.
+        /// Applies an asynchronous (cancellable) accumulator function over an async-enumerable sequence and returns each intermediate result. The specified seed value is used as the initial accumulator value.
         /// For aggregation behavior with no intermediate results, see <see cref="AsyncEnumerable.AggregateAsync{TSource, Accumulate}"/>.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TAccumulate">The type of the result of the aggregation.</typeparam>
-        /// <param name="source">An observable sequence to accumulate over.</param>
+        /// <param name="source">An async-enumerable sequence to accumulate over.</param>
         /// <param name="seed">The initial accumulator value.</param>
         /// <param name="accumulator">An asynchronous (cancellable) accumulator function to be invoked on each element.</param>
-        /// <returns>An observable sequence containing the accumulated values.</returns>
+        /// <returns>An async-enumerable sequence containing the accumulated values.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="accumulator"/> is null.</exception>
         public static IAsyncEnumerable<TAccumulate> Scan<TSource, TAccumulate>(this IAsyncEnumerable<TSource> source, TAccumulate seed, Func<TAccumulate, TSource, CancellationToken, ValueTask<TAccumulate>> accumulator)
         {

+ 4 - 4
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/SelectMany.cs

@@ -9,13 +9,13 @@ namespace System.Linq
     public static partial class AsyncEnumerableEx
     {
         /// <summary>
-        /// Projects each element of the source observable sequence to the other observable sequence and merges the resulting observable sequences into one observable sequence.
+        /// Projects each element of the source async-enumerable sequence to the other async-enumerable sequence and merges the resulting async-enumerable sequences into one async-enumerable sequence.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <typeparam name="TOther">The type of the elements in the other sequence and the elements in the result sequence.</typeparam>
-        /// <param name="source">An observable sequence of elements to project.</param>
-        /// <param name="other">An observable sequence to project each element from the source sequence onto.</param>
-        /// <returns>An observable sequence whose elements are the result of projecting each source element onto the other sequence and merging all the resulting sequences together.</returns>
+        /// <param name="source">An async-enumerable sequence of elements to project.</param>
+        /// <param name="other">An async-enumerable sequence to project each element from the source sequence onto.</param>
+        /// <returns>An async-enumerable sequence whose elements are the result of projecting each source element onto the other sequence and merging all the resulting sequences together.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="other"/> is null.</exception>
         public static IAsyncEnumerable<TOther> SelectMany<TSource, TOther>(this IAsyncEnumerable<TSource> source, IAsyncEnumerable<TOther> other)
         {

+ 1 - 1
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/StartWith.cs

@@ -12,7 +12,7 @@ namespace System.Linq
         //         If so, likely in Ix rather than System.Linq.Async.
 
         /// <summary>
-        /// Prepends a sequence of values to an observable sequence.
+        /// Prepends a sequence of values to an async-enumerable sequence.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>
         /// <param name="source">Source sequence to prepend values to.</param>

+ 2 - 2
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Throw.cs

@@ -11,11 +11,11 @@ namespace System.Linq
     public static partial class AsyncEnumerableEx
     {
         /// <summary>
-        /// Returns an observable sequence that terminates with an exception.
+        /// Returns an async-enumerable sequence that terminates with an exception.
         /// </summary>
         /// <typeparam name="TValue">The type used for the <see cref="IAsyncEnumerable{T}"/> type parameter of the resulting sequence.</typeparam>
         /// <param name="exception">Exception object used for the sequence's termination.</param>
-        /// <returns>The observable sequence that terminates exceptionally with the specified exception object.</returns>
+        /// <returns>The async-enumerable sequence that terminates exceptionally with the specified exception object.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="exception"/> is null.</exception>
         public static IAsyncEnumerable<TValue> Throw<TValue>(Exception exception)
         {

+ 1 - 1
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Timeout.cs

@@ -11,7 +11,7 @@ namespace System.Linq
     public static partial class AsyncEnumerableEx
     {
         /// <summary>
-        /// Applies a timeout policy for each element in the observable sequence.
+        /// Applies a timeout policy for each element in the async-enumerable sequence.
         /// If the next element isn't received within the specified timeout duration starting from its predecessor, a TimeoutException is propagated to the observer.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the source sequence.</typeparam>

+ 11 - 11
Ix.NET/Source/System.Interactive.Async/System/Linq/Operators/Using.cs

@@ -13,13 +13,13 @@ namespace System.Linq
         // REVIEW: Add support for IAsyncDisposable resources.
 
         /// <summary>
-        /// Constructs an observable sequence that depends on a resource object, whose lifetime is tied to the resulting observable sequence's lifetime.
+        /// Constructs an async-enumerable sequence that depends on a resource object, whose lifetime is tied to the resulting async-enumerable sequence's lifetime.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the produced sequence.</typeparam>
         /// <typeparam name="TResource">The type of the resource used during the generation of the resulting sequence. Needs to implement <see cref="IDisposable"/>.</typeparam>
         /// <param name="resourceFactory">Factory function to obtain a resource object.</param>
-        /// <param name="enumerableFactory">Factory function to obtain an observable sequence that depends on the obtained resource.</param>
-        /// <returns>An observable sequence whose lifetime controls the lifetime of the dependent resource object.</returns>
+        /// <param name="enumerableFactory">Factory function to obtain an async-enumerable sequence that depends on the obtained resource.</param>
+        /// <returns>An async-enumerable sequence whose lifetime controls the lifetime of the dependent resource object.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="resourceFactory"/> or <paramref name="enumerableFactory"/> is null.</exception>
         public static IAsyncEnumerable<TSource> Using<TSource, TResource>(Func<TResource> resourceFactory, Func<TResource, IAsyncEnumerable<TSource>> enumerableFactory) where TResource : IDisposable
         {
@@ -42,16 +42,16 @@ namespace System.Linq
         }
 
         /// <summary>
-        /// Constructs an observable sequence that depends on a resource object, whose lifetime is tied to the resulting observable sequence's lifetime.
+        /// Constructs an async-enumerable sequence that depends on a resource object, whose lifetime is tied to the resulting async-enumerable sequence's lifetime.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the produced sequence.</typeparam>
         /// <typeparam name="TResource">The type of the resource used during the generation of the resulting sequence. Needs to implement <see cref="IDisposable"/>.</typeparam>
         /// <param name="resourceFactory">Asynchronous factory function to obtain a resource object.</param>
-        /// <param name="enumerableFactory">Asynchronous factory function to obtain an observable sequence that depends on the obtained resource.</param>
-        /// <returns>An observable sequence whose lifetime controls the lifetime of the dependent resource object.</returns>
+        /// <param name="enumerableFactory">Asynchronous factory function to obtain an async-enumerable sequence that depends on the obtained resource.</param>
+        /// <returns>An async-enumerable sequence whose lifetime controls the lifetime of the dependent resource object.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="resourceFactory"/> or <paramref name="enumerableFactory"/> is null.</exception>
         /// <remarks>This operator is especially useful in conjunction with the asynchronous programming features introduced in C# 5.0 and Visual Basic 11.</remarks>
-        /// <remarks>When a subscription to the resulting sequence is disposed, the CancellationToken that was fed to the asynchronous resource factory and observable factory functions will be signaled.</remarks>
+        /// <remarks>When a subscription to the resulting sequence is disposed, the CancellationToken that was fed to the asynchronous resource factory and async-enumerable factory functions will be signaled.</remarks>
         public static IAsyncEnumerable<TSource> Using<TSource, TResource>(Func<Task<TResource>> resourceFactory, Func<TResource, ValueTask<IAsyncEnumerable<TSource>>> enumerableFactory) where TResource : IDisposable
         {
             if (resourceFactory == null)
@@ -74,17 +74,17 @@ namespace System.Linq
 
 #if !NO_DEEP_CANCELLATION
         /// <summary>
-        /// Constructs an observable sequence that depends on a resource object, whose lifetime is tied to the resulting observable sequence's lifetime. The resource is obtained and used through asynchronous methods.
+        /// Constructs an async-enumerable sequence that depends on a resource object, whose lifetime is tied to the resulting async-enumerable sequence's lifetime. The resource is obtained and used through asynchronous methods.
         /// The CancellationToken passed to the asynchronous methods is tied to the returned disposable subscription, allowing best-effort cancellation at any stage of the resource acquisition or usage.
         /// </summary>
         /// <typeparam name="TSource">The type of the elements in the produced sequence.</typeparam>
         /// <typeparam name="TResource">The type of the resource used during the generation of the resulting sequence. Needs to implement <see cref="IDisposable"/>.</typeparam>
         /// <param name="resourceFactory">Asynchronous factory function to obtain a resource object.</param>
-        /// <param name="enumerableFactory">Asynchronous factory function to obtain an observable sequence that depends on the obtained resource.</param>
-        /// <returns>An observable sequence whose lifetime controls the lifetime of the dependent resource object.</returns>
+        /// <param name="enumerableFactory">Asynchronous factory function to obtain an async-enumerable sequence that depends on the obtained resource.</param>
+        /// <returns>An async-enumerable sequence whose lifetime controls the lifetime of the dependent resource object.</returns>
         /// <exception cref="ArgumentNullException"><paramref name="resourceFactory"/> or <paramref name="enumerableFactory"/> is null.</exception>
         /// <remarks>This operator is especially useful in conjunction with the asynchronous programming features introduced in C# 5.0 and Visual Basic 11.</remarks>
-        /// <remarks>When a subscription to the resulting sequence is disposed, the CancellationToken that was fed to the asynchronous resource factory and observable factory functions will be signaled.</remarks>
+        /// <remarks>When a subscription to the resulting sequence is disposed, the CancellationToken that was fed to the asynchronous resource factory and async-enumerable factory functions will be signaled.</remarks>
         public static IAsyncEnumerable<TSource> Using<TSource, TResource>(Func<CancellationToken, Task<TResource>> resourceFactory, Func<TResource, CancellationToken, ValueTask<IAsyncEnumerable<TSource>>> enumerableFactory) where TResource : IDisposable
         {
             if (resourceFactory == null)