Update HomoIcon tool to reflect new repository structure and manual code changes (#537)

Rx.NET/Source/src/System.Reactive.Observable.Aliases/Qbservable.Aliases.Generated.cs

@@ -1,22 +1,22 @@
 /*
- * WARNING: Auto-generated file (5/1/2015 21:21:20)
+ * WARNING: Auto-generated file (05/28/2018 22:20:19)
  * Run Rx's auto-homoiconizer tool to generate this file (in the HomoIcon directory).
  */
 
 #pragma warning disable 1591
 
 using System;
+using System.Reactive.Concurrency;
 using System.Collections.Generic;
 using System.Diagnostics.CodeAnalysis;
+using System.Reactive.Joins;
 using System.Linq;
 using System.Linq.Expressions;
-using System.Reactive;
-using System.Reactive.Concurrency;
-using System.Reactive.Joins;
-using System.Reactive.Subjects;
 using System.Reflection;
 using System.Threading;
 using System.Threading.Tasks;
+using System.Reactive;
+using System.Reactive.Subjects;
 
 namespace System.Reactive.Linq
 {
@@ -37,7 +37,7 @@ namespace System.Reactive.Linq
         {
             return Qbservable.Where<TSource>(source, predicate);
         }
-        
+
         /// <summary>
         /// Filters the elements of an observable sequence based on a predicate by incorporating the element's index.
         /// Synonym for the method 'Where'
@@ -52,7 +52,7 @@ namespace System.Reactive.Linq
         {
             return Qbservable.Where<TSource>(source, predicate);
         }
-        
+
         /// <summary>
         /// Projects each element of an observable sequence to an observable sequence, invokes the result selector for the source element and each of the corresponding inner sequence's elements, and merges the results into one observable sequence.
         /// Synonym for the method 'SelectMany'
@@ -70,7 +70,7 @@ namespace System.Reactive.Linq
         {
             return Qbservable.SelectMany<TSource, TCollection, TResult>(source, collectionSelector, resultSelector);
         }
-        
+
         /// <summary>
         /// Projects each element of an observable sequence to an observable sequence by incorporating the element's index, invokes the result selector for the source element and each of the corresponding inner sequence's elements, and merges the results into one observable sequence.
         /// Synonym for the method 'SelectMany'
@@ -88,7 +88,7 @@ namespace System.Reactive.Linq
         {
             return Qbservable.SelectMany<TSource, TCollection, TResult>(source, collectionSelector, resultSelector);
         }
-        
+
         /// <summary>
         /// Projects each element of an observable sequence to an enumerable sequence, invokes the result selector for the source element and each of the corresponding inner sequence's elements, and merges the results into one observable sequence.
         /// Synonym for the method 'SelectMany'
@@ -102,12 +102,12 @@ namespace System.Reactive.Linq
         /// <returns>An observable sequence whose elements are the result of invoking the one-to-many transform function collectionSelector on each element of the input sequence and then mapping each of those sequence elements and their corresponding source element to a result element.</returns>
         /// <exception cref="ArgumentNullException">
         /// <paramref name="source" /> or <paramref name="collectionSelector" /> or <paramref name="resultSelector" /> is null.</exception>
-        /// <remarks>The projected sequences are enumerated synchonously within the OnNext call of the source sequence. In order to do a concurrent, non-blocking merge, change the selector to return an observable sequence obtained using the <see cref="Observable.ToObservable{TSource}(IEnumerable{TSource})" /> conversion.</remarks>
+        /// <remarks>The projected sequences are enumerated synchonously within the OnNext call of the source sequence. In order to do a concurrent, non-blocking merge, change the selector to return an observable sequence obtained using the <see cref="M:System.Reactive.Linq.Observable.ToObservable``1(System.Collections.Generic.IEnumerable{``0})" /> conversion.</remarks>
         public static IQbservable<TResult> FlatMap<TSource, TCollection, TResult>(this IQbservable<TSource> source, Expression<Func<TSource, IEnumerable<TCollection>>> collectionSelector, Expression<Func<TSource, TCollection, TResult>> resultSelector)
         {
             return Qbservable.SelectMany<TSource, TCollection, TResult>(source, collectionSelector, resultSelector);
         }
-        
+
         /// <summary>
         /// Projects each element of an observable sequence to an enumerable sequence by incorporating the element's index, invokes the result selector for the source element and each of the corresponding inner sequence's elements, and merges the results into one observable sequence.
         /// Synonym for the method 'SelectMany'
@@ -121,12 +121,12 @@ namespace System.Reactive.Linq
         /// <returns>An observable sequence whose elements are the result of invoking the one-to-many transform function collectionSelector on each element of the input sequence and then mapping each of those sequence elements and their corresponding source element to a result element.</returns>
         /// <exception cref="ArgumentNullException">
         /// <paramref name="source" /> or <paramref name="collectionSelector" /> or <paramref name="resultSelector" /> is null.</exception>
-        /// <remarks>The projected sequences are enumerated synchonously within the OnNext call of the source sequence. In order to do a concurrent, non-blocking merge, change the selector to return an observable sequence obtained using the <see cref="Observable.ToObservable{TSource}(IEnumerable{TSource})" /> conversion.</remarks>
+        /// <remarks>The projected sequences are enumerated synchonously within the OnNext call of the source sequence. In order to do a concurrent, non-blocking merge, change the selector to return an observable sequence obtained using the <see cref="M:System.Reactive.Linq.Observable.ToObservable``1(System.Collections.Generic.IEnumerable{``0})" /> conversion.</remarks>
         public static IQbservable<TResult> FlatMap<TSource, TCollection, TResult>(this IQbservable<TSource> source, Expression<Func<TSource, int, IEnumerable<TCollection>>> collectionSelector, Expression<Func<TSource, int, TCollection, int, TResult>> resultSelector)
         {
             return Qbservable.SelectMany<TSource, TCollection, TResult>(source, collectionSelector, resultSelector);
         }
-        
+
         /// <summary>
         /// Projects each element of the source observable sequence to the other observable sequence and merges the resulting observable sequences into one observable sequence. 
         /// Synonym for the method 'SelectMany'
@@ -142,7 +142,7 @@ namespace System.Reactive.Linq
         {
             return Qbservable.SelectMany<TSource, TOther>(source, other);
         }
-        
+
         /// <summary>
         /// Projects each notification of an observable sequence to an observable sequence and merges the resulting observable sequences into one observable sequence.
         /// Synonym for the method 'SelectMany'
@@ -160,7 +160,7 @@ namespace System.Reactive.Linq
         {
             return Qbservable.SelectMany<TSource, TResult>(source, onNext, onError, onCompleted);
         }
-        
+
         /// <summary>
         /// Projects each notification of an observable sequence to an observable sequence by incorporating the element's index and merges the resulting observable sequences into one observable sequence.
         /// Synonym for the method 'SelectMany'
@@ -178,7 +178,7 @@ namespace System.Reactive.Linq
         {
             return Qbservable.SelectMany<TSource, TResult>(source, onNext, onError, onCompleted);
         }
-        
+
         /// <summary>
         /// Projects each element of an observable sequence to an observable sequence and merges the resulting observable sequences into one observable sequence.
         /// Synonym for the method 'SelectMany'
@@ -194,7 +194,7 @@ namespace System.Reactive.Linq
         {
             return Qbservable.SelectMany<TSource, TResult>(source, selector);
         }
-        
+
         /// <summary>
         /// Projects each element of an observable sequence to an observable sequence by incorporating the element's index and merges the resulting observable sequences into one observable sequence.
         /// Synonym for the method 'SelectMany'
@@ -210,7 +210,7 @@ namespace System.Reactive.Linq
         {
             return Qbservable.SelectMany<TSource, TResult>(source, selector);
         }
-        
+
         /// <summary>
         /// Projects each element of an observable sequence to a task and merges all of the task results into one observable sequence.
         /// Synonym for the method 'SelectMany'
@@ -220,14 +220,14 @@ namespace System.Reactive.Linq
         /// <param name="source">An observable sequence of elements to project.</param>
         /// <param name="selector">A transform function to apply to each element.</param>
         /// <returns>An observable sequence whose elements are the result of the tasks executed for each element of the input sequence.</returns>
-        /// <remarks>This overload supports composition of observable sequences and tasks, without requiring manual conversion of the tasks to observable sequences using <see cref="Reactive.Threading.Tasks.TaskObservableExtensions.ToObservable{TSource}(Task{TSource})" />.</remarks>
+        /// <remarks>This overload supports composition of observable sequences and tasks, without requiring manual conversion of the tasks to observable sequences using <see cref="M:System.Reactive.Threading.Tasks.TaskObservableExtensions.ToObservable``1(System.Threading.Tasks.Task{``0})" />.</remarks>
         /// <exception cref="ArgumentNullException">
         /// <paramref name="source" /> or <paramref name="selector" /> is null.</exception>
         public static IQbservable<TResult> FlatMap<TSource, TResult>(this IQbservable<TSource> source, Expression<Func<TSource, Task<TResult>>> selector)
         {
             return Qbservable.SelectMany<TSource, TResult>(source, selector);
         }
-        
+
         /// <summary>
         /// Projects each element of an observable sequence to a task by incorporating the element's index and merges all of the task results into one observable sequence.
         /// Synonym for the method 'SelectMany'
@@ -237,14 +237,14 @@ namespace System.Reactive.Linq
         /// <param name="source">An observable sequence of elements to project.</param>
         /// <param name="selector">A transform function to apply to each element; the second parameter of the function represents the index of the source element.</param>
         /// <returns>An observable sequence whose elements are the result of the tasks executed for each element of the input sequence.</returns>
-        /// <remarks>This overload supports composition of observable sequences and tasks, without requiring manual conversion of the tasks to observable sequences using <see cref="Reactive.Threading.Tasks.TaskObservableExtensions.ToObservable{TSource}(Task{TSource})" />.</remarks>
+        /// <remarks>This overload supports composition of observable sequences and tasks, without requiring manual conversion of the tasks to observable sequences using <see cref="M:System.Reactive.Threading.Tasks.TaskObservableExtensions.ToObservable``1(System.Threading.Tasks.Task{``0})" />.</remarks>
         /// <exception cref="ArgumentNullException">
         /// <paramref name="source" /> or <paramref name="selector" /> is null.</exception>
         public static IQbservable<TResult> FlatMap<TSource, TResult>(this IQbservable<TSource> source, Expression<Func<TSource, int, Task<TResult>>> selector)
         {
             return Qbservable.SelectMany<TSource, TResult>(source, selector);
         }
-        
+
         /// <summary>
         /// Projects each element of an observable sequence to a task with cancellation support and merges all of the task results into one observable sequence.
         /// Synonym for the method 'SelectMany'
@@ -254,14 +254,14 @@ namespace System.Reactive.Linq
         /// <param name="source">An observable sequence of elements to project.</param>
         /// <param name="selector">A transform function to apply to each element.</param>
         /// <returns>An observable sequence whose elements are the result of the tasks executed for each element of the input sequence.</returns>
-        /// <remarks>This overload supports composition of observable sequences and tasks, without requiring manual conversion of the tasks to observable sequences using <see cref="Reactive.Threading.Tasks.TaskObservableExtensions.ToObservable{TSource}(Task{TSource})" />.</remarks>
+        /// <remarks>This overload supports composition of observable sequences and tasks, without requiring manual conversion of the tasks to observable sequences using <see cref="M:System.Reactive.Threading.Tasks.TaskObservableExtensions.ToObservable``1(System.Threading.Tasks.Task{``0})" />.</remarks>
         /// <exception cref="ArgumentNullException">
         /// <paramref name="source" /> or <paramref name="selector" /> is null.</exception>
         public static IQbservable<TResult> FlatMap<TSource, TResult>(this IQbservable<TSource> source, Expression<Func<TSource, CancellationToken, Task<TResult>>> selector)
         {
             return Qbservable.SelectMany<TSource, TResult>(source, selector);
         }
-        
+
         /// <summary>
         /// Projects each element of an observable sequence to a task by incorporating the element's index with cancellation support and merges all of the task results into one observable sequence.
         /// Synonym for the method 'SelectMany'
@@ -271,14 +271,14 @@ namespace System.Reactive.Linq
         /// <param name="source">An observable sequence of elements to project.</param>
         /// <param name="selector">A transform function to apply to each element; the second parameter of the function represents the index of the source element.</param>
         /// <returns>An observable sequence whose elements are the result of the tasks executed for each element of the input sequence.</returns>
-        /// <remarks>This overload supports composition of observable sequences and tasks, without requiring manual conversion of the tasks to observable sequences using <see cref="Reactive.Threading.Tasks.TaskObservableExtensions.ToObservable{TSource}(Task{TSource})" />.</remarks>
+        /// <remarks>This overload supports composition of observable sequences and tasks, without requiring manual conversion of the tasks to observable sequences using <see cref="M:System.Reactive.Threading.Tasks.TaskObservableExtensions.ToObservable``1(System.Threading.Tasks.Task{``0})" />.</remarks>
         /// <exception cref="ArgumentNullException">
         /// <paramref name="source" /> or <paramref name="selector" /> is null.</exception>
         public static IQbservable<TResult> FlatMap<TSource, TResult>(this IQbservable<TSource> source, Expression<Func<TSource, int, CancellationToken, Task<TResult>>> selector)
         {
             return Qbservable.SelectMany<TSource, TResult>(source, selector);
         }
-        
+
         /// <summary>
         /// Projects each element of an observable sequence to an enumerable sequence and concatenates the resulting enumerable sequences into one observable sequence.
         /// Synonym for the method 'SelectMany'
@@ -290,12 +290,12 @@ namespace System.Reactive.Linq
         /// <returns>An observable sequence whose elements are the result of invoking the one-to-many transform function on each element of the input sequence.</returns>
         /// <exception cref="ArgumentNullException">
         /// <paramref name="source" /> or <paramref name="selector" /> is null.</exception>
-        /// <remarks>The projected sequences are enumerated synchonously within the OnNext call of the source sequence. In order to do a concurrent, non-blocking merge, change the selector to return an observable sequence obtained using the <see cref="Observable.ToObservable{TSource}(IEnumerable{TSource})" /> conversion.</remarks>
+        /// <remarks>The projected sequences are enumerated synchonously within the OnNext call of the source sequence. In order to do a concurrent, non-blocking merge, change the selector to return an observable sequence obtained using the <see cref="M:System.Reactive.Linq.Observable.ToObservable``1(System.Collections.Generic.IEnumerable{``0})" /> conversion.</remarks>
         public static IQbservable<TResult> FlatMap<TSource, TResult>(this IQbservable<TSource> source, Expression<Func<TSource, IEnumerable<TResult>>> selector)
         {
             return Qbservable.SelectMany<TSource, TResult>(source, selector);
         }
-        
+
         /// <summary>
         /// Projects each element of an observable sequence to an enumerable sequence by incorporating the element's index and concatenates the resulting enumerable sequences into one observable sequence.
         /// Synonym for the method 'SelectMany'
@@ -307,12 +307,12 @@ namespace System.Reactive.Linq
         /// <returns>An observable sequence whose elements are the result of invoking the one-to-many transform function on each element of the input sequence.</returns>
         /// <exception cref="ArgumentNullException">
         /// <paramref name="source" /> or <paramref name="selector" /> is null.</exception>
-        /// <remarks>The projected sequences are enumerated synchonously within the OnNext call of the source sequence. In order to do a concurrent, non-blocking merge, change the selector to return an observable sequence obtained using the <see cref="Observable.ToObservable{TSource}(IEnumerable{TSource})" /> conversion.</remarks>
+        /// <remarks>The projected sequences are enumerated synchonously within the OnNext call of the source sequence. In order to do a concurrent, non-blocking merge, change the selector to return an observable sequence obtained using the <see cref="M:System.Reactive.Linq.Observable.ToObservable``1(System.Collections.Generic.IEnumerable{``0})" /> conversion.</remarks>
         public static IQbservable<TResult> FlatMap<TSource, TResult>(this IQbservable<TSource> source, Expression<Func<TSource, int, IEnumerable<TResult>>> selector)
         {
             return Qbservable.SelectMany<TSource, TResult>(source, selector);
         }
-        
+
         /// <summary>
         /// Projects each element of an observable sequence to a task, invokes the result selector for the source element and the task result, and merges the results into one observable sequence.
         /// Synonym for the method 'SelectMany'
@@ -326,12 +326,12 @@ namespace System.Reactive.Linq
         /// <returns>An observable sequence whose elements are the result of obtaining a task for each element of the input sequence and then mapping the task's result and its corresponding source element to a result element.</returns>
         /// <exception cref="ArgumentNullException">
         /// <paramref name="source" /> or <paramref name="taskSelector" /> or <paramref name="resultSelector" /> is null.</exception>
-        /// <remarks>This overload supports using LINQ query comprehension syntax in C# and Visual Basic to compose observable sequences and tasks, without requiring manual conversion of the tasks to observable sequences using <see cref="Reactive.Threading.Tasks.TaskObservableExtensions.ToObservable{TSource}(Task{TSource})" />.</remarks>
+        /// <remarks>This overload supports using LINQ query comprehension syntax in C# and Visual Basic to compose observable sequences and tasks, without requiring manual conversion of the tasks to observable sequences using <see cref="M:System.Reactive.Threading.Tasks.TaskObservableExtensions.ToObservable``1(System.Threading.Tasks.Task{``0})" />.</remarks>
         public static IQbservable<TResult> FlatMap<TSource, TTaskResult, TResult>(this IQbservable<TSource> source, Expression<Func<TSource, Task<TTaskResult>>> taskSelector, Expression<Func<TSource, TTaskResult, TResult>> resultSelector)
         {
             return Qbservable.SelectMany<TSource, TTaskResult, TResult>(source, taskSelector, resultSelector);
         }
-        
+
         /// <summary>
         /// Projects each element of an observable sequence to a task by incorporating the element's index, invokes the result selector for the source element and the task result, and merges the results into one observable sequence.
         /// Synonym for the method 'SelectMany'
@@ -345,12 +345,12 @@ namespace System.Reactive.Linq
         /// <returns>An observable sequence whose elements are the result of obtaining a task for each element of the input sequence and then mapping the task's result and its corresponding source element to a result element.</returns>
         /// <exception cref="ArgumentNullException">
         /// <paramref name="source" /> or <paramref name="taskSelector" /> or <paramref name="resultSelector" /> is null.</exception>
-        /// <remarks>This overload supports using LINQ query comprehension syntax in C# and Visual Basic to compose observable sequences and tasks, without requiring manual conversion of the tasks to observable sequences using <see cref="Reactive.Threading.Tasks.TaskObservableExtensions.ToObservable{TSource}(Task{TSource})" />.</remarks>
+        /// <remarks>This overload supports using LINQ query comprehension syntax in C# and Visual Basic to compose observable sequences and tasks, without requiring manual conversion of the tasks to observable sequences using <see cref="M:System.Reactive.Threading.Tasks.TaskObservableExtensions.ToObservable``1(System.Threading.Tasks.Task{``0})" />.</remarks>
         public static IQbservable<TResult> FlatMap<TSource, TTaskResult, TResult>(this IQbservable<TSource> source, Expression<Func<TSource, int, Task<TTaskResult>>> taskSelector, Expression<Func<TSource, int, TTaskResult, TResult>> resultSelector)
         {
             return Qbservable.SelectMany<TSource, TTaskResult, TResult>(source, taskSelector, resultSelector);
         }
-        
+
         /// <summary>
         /// Projects each element of an observable sequence to a task with cancellation support, invokes the result selector for the source element and the task result, and merges the results into one observable sequence.
         /// Synonym for the method 'SelectMany'
@@ -364,12 +364,12 @@ namespace System.Reactive.Linq
         /// <returns>An observable sequence whose elements are the result of obtaining a task for each element of the input sequence and then mapping the task's result and its corresponding source element to a result element.</returns>
         /// <exception cref="ArgumentNullException">
         /// <paramref name="source" /> or <paramref name="taskSelector" /> or <paramref name="resultSelector" /> is null.</exception>
-        /// <remarks>This overload supports using LINQ query comprehension syntax in C# and Visual Basic to compose observable sequences and tasks, without requiring manual conversion of the tasks to observable sequences using <see cref="Reactive.Threading.Tasks.TaskObservableExtensions.ToObservable{TSource}(Task{TSource})" />.</remarks>
+        /// <remarks>This overload supports using LINQ query comprehension syntax in C# and Visual Basic to compose observable sequences and tasks, without requiring manual conversion of the tasks to observable sequences using <see cref="M:System.Reactive.Threading.Tasks.TaskObservableExtensions.ToObservable``1(System.Threading.Tasks.Task{``0})" />.</remarks>
         public static IQbservable<TResult> FlatMap<TSource, TTaskResult, TResult>(this IQbservable<TSource> source, Expression<Func<TSource, CancellationToken, Task<TTaskResult>>> taskSelector, Expression<Func<TSource, TTaskResult, TResult>> resultSelector)
         {
             return Qbservable.SelectMany<TSource, TTaskResult, TResult>(source, taskSelector, resultSelector);
         }
-        
+
         /// <summary>
         /// Projects each element of an observable sequence to a task by incorporating the element's index with cancellation support, invokes the result selector for the source element and the task result, and merges the results into one observable sequence.
         /// Synonym for the method 'SelectMany'
@@ -383,12 +383,12 @@ namespace System.Reactive.Linq
         /// <returns>An observable sequence whose elements are the result of obtaining a task for each element of the input sequence and then mapping the task's result and its corresponding source element to a result element.</returns>
         /// <exception cref="ArgumentNullException">
         /// <paramref name="source" /> or <paramref name="taskSelector" /> or <paramref name="resultSelector" /> is null.</exception>
-        /// <remarks>This overload supports using LINQ query comprehension syntax in C# and Visual Basic to compose observable sequences and tasks, without requiring manual conversion of the tasks to observable sequences using <see cref="Reactive.Threading.Tasks.TaskObservableExtensions.ToObservable{TSource}(Task{TSource})" />.</remarks>
+        /// <remarks>This overload supports using LINQ query comprehension syntax in C# and Visual Basic to compose observable sequences and tasks, without requiring manual conversion of the tasks to observable sequences using <see cref="M:System.Reactive.Threading.Tasks.TaskObservableExtensions.ToObservable``1(System.Threading.Tasks.Task{``0})" />.</remarks>
         public static IQbservable<TResult> FlatMap<TSource, TTaskResult, TResult>(this IQbservable<TSource> source, Expression<Func<TSource, int, CancellationToken, Task<TTaskResult>>> taskSelector, Expression<Func<TSource, int, TTaskResult, TResult>> resultSelector)
         {
             return Qbservable.SelectMany<TSource, TTaskResult, TResult>(source, taskSelector, resultSelector);
         }
-        
+
         /// <summary>
         /// Projects each element of an observable sequence into a new form. Synonym for the method 'Select'
         /// </summary>
@@ -403,7 +403,7 @@ namespace System.Reactive.Linq
         {
             return Qbservable.Select<TSource, TResult>(source, selector);
         }
-        
+
         /// <summary>
         /// Projects each element of an observable sequence into a new form by incorporating the element's index. Synonym for the method 'Select'
         /// </summary>
@@ -418,7 +418,7 @@ namespace System.Reactive.Linq
         {
             return Qbservable.Select<TSource, TResult>(source, selector);
         }
-        
+
     }
 }
 

Rx.NET/Source/src/System.Reactive.Observable.Aliases/System.Reactive.Observable.Aliases.csproj

@@ -1,6 +1,6 @@
 <Project Sdk="MSBuild.Sdk.Extras">
   <PropertyGroup>
-    <TargetFrameworks>uap10.0;netstandard2.0;net46</TargetFrameworks>    
+    <TargetFrameworks>netstandard2.0;net46;uap10.0</TargetFrameworks>    
     <Title>Reactive Extensions - Aliases</Title>    
     <CopyLocalLockFileAssemblies>false</CopyLocalLockFileAssemblies>    
     <PackageTags>Rx;Reactive;Extensions;Observable;LINQ;Events</PackageTags>

Rx.NET/Source/src/System.Reactive/Linq/QbservableEx.Generated.cs

@@ -1,5 +1,5 @@
-/*
- * WARNING: Auto-generated file (5/1/2015 21:21:20)
+/*
+ * WARNING: Auto-generated file (05/28/2018 22:20:19)
  * Run Rx's auto-homoiconizer tool to generate this file (in the HomoIcon directory).
  */
 
@@ -37,7 +37,7 @@ namespace System.Reactive.Linq
                 throw new ArgumentNullException(nameof(provider));
             if (iteratorMethod == null)
                 throw new ArgumentNullException(nameof(iteratorMethod));
-            
+
             return provider.CreateQuery<Unit>(
                 Expression.Call(
                     null,
@@ -52,7 +52,7 @@ namespace System.Reactive.Linq
             );
         }
 #endif
-        
+
 #if !STABLE
         /// <summary>
         /// Subscribes to each observable sequence returned by the iteratorMethod in sequence and returns the observable sequence of values sent to the observer given to the iteratorMethod.
@@ -70,7 +70,7 @@ namespace System.Reactive.Linq
                 throw new ArgumentNullException(nameof(provider));
             if (iteratorMethod == null)
                 throw new ArgumentNullException(nameof(iteratorMethod));
-            
+
             return provider.CreateQuery<TResult>(
                 Expression.Call(
                     null,
@@ -85,7 +85,7 @@ namespace System.Reactive.Linq
             );
         }
 #endif
-        
+
 #if !STABLE
         /// <summary>
         /// Expands an observable sequence by recursively invoking selector.
@@ -103,7 +103,7 @@ namespace System.Reactive.Linq
                 throw new ArgumentNullException(nameof(source));
             if (selector == null)
                 throw new ArgumentNullException(nameof(selector));
-            
+
             return source.Provider.CreateQuery<TSource>(
                 Expression.Call(
                     null,
@@ -118,7 +118,7 @@ namespace System.Reactive.Linq
             );
         }
 #endif
-        
+
 #if !STABLE
         /// <summary>
         /// Expands an observable sequence by recursively invoking selector, using the specified scheduler to enumerate the queue of obtained sequences.
@@ -139,7 +139,7 @@ namespace System.Reactive.Linq
                 throw new ArgumentNullException(nameof(selector));
             if (scheduler == null)
                 throw new ArgumentNullException(nameof(scheduler));
-            
+
             return source.Provider.CreateQuery<TSource>(
                 Expression.Call(
                     null,
@@ -155,7 +155,7 @@ namespace System.Reactive.Linq
             );
         }
 #endif
-        
+
 #if !STABLE
         /// <summary>
         /// Runs all specified observable sequences in parallel and collects their last elements.
@@ -173,7 +173,7 @@ namespace System.Reactive.Linq
                 throw new ArgumentNullException(nameof(provider));
             if (sources == null)
                 throw new ArgumentNullException(nameof(sources));
-            
+
             return provider.CreateQuery<TSource[]>(
                 Expression.Call(
                     null,
@@ -188,7 +188,7 @@ namespace System.Reactive.Linq
             );
         }
 #endif
-        
+
 #if !STABLE
         /// <summary>
         /// Runs all observable sequences in the enumerable sources sequence in parallel and collect their last elements.
@@ -206,7 +206,7 @@ namespace System.Reactive.Linq
                 throw new ArgumentNullException(nameof(provider));
             if (sources == null)
                 throw new ArgumentNullException(nameof(sources));
-            
+
             return provider.CreateQuery<TSource[]>(
                 Expression.Call(
                     null,
@@ -221,7 +221,7 @@ namespace System.Reactive.Linq
             );
         }
 #endif
-        
+
 #if !STABLE
         /// <summary>
         /// Runs two observable sequences in parallel and combines their last elements.
@@ -244,7 +244,7 @@ namespace System.Reactive.Linq
                 throw new ArgumentNullException(nameof(second));
             if (resultSelector == null)
                 throw new ArgumentNullException(nameof(resultSelector));
-            
+
             return first.Provider.CreateQuery<TResult>(
                 Expression.Call(
                     null,
@@ -260,7 +260,7 @@ namespace System.Reactive.Linq
             );
         }
 #endif
-        
+
 #if !STABLE
         /// <summary>
         /// Returns an observable sequence that is the result of invoking the selector on the source sequence, without sharing subscriptions.
@@ -280,7 +280,7 @@ namespace System.Reactive.Linq
                 throw new ArgumentNullException(nameof(source));
             if (selector == null)
                 throw new ArgumentNullException(nameof(selector));
-            
+
             return source.Provider.CreateQuery<TResult>(
                 Expression.Call(
                     null,
@@ -295,7 +295,7 @@ namespace System.Reactive.Linq
             );
         }
 #endif
-        
+
 #if !STABLE
         /// <summary>
         /// Comonadic bind operator.
@@ -307,7 +307,7 @@ namespace System.Reactive.Linq
                 throw new ArgumentNullException(nameof(source));
             if (selector == null)
                 throw new ArgumentNullException(nameof(selector));
-            
+
             return source.Provider.CreateQuery<TResult>(
                 Expression.Call(
                     null,
@@ -322,7 +322,7 @@ namespace System.Reactive.Linq
             );
         }
 #endif
-        
+
 #if !STABLE
         /// <summary>
         /// Comonadic bind operator.
@@ -336,7 +336,7 @@ namespace System.Reactive.Linq
                 throw new ArgumentNullException(nameof(selector));
             if (scheduler == null)
                 throw new ArgumentNullException(nameof(scheduler));
-            
+
             return source.Provider.CreateQuery<TResult>(
                 Expression.Call(
                     null,
@@ -352,7 +352,7 @@ namespace System.Reactive.Linq
             );
         }
 #endif
-        
+
     }
 }
 

Rx.NET/Source/tests/Tests.System.Reactive.ApiApprovals/Api/ApiApprovalTests.Core.approved.txt

@@ -1621,7 +1621,7 @@ namespace System.Reactive.Linq
         public static System.Reactive.Linq.IQbservable<bool> Any<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, bool>> predicate) { }
         public static System.IObservable<TSource> AsObservable<TSource>(this System.Reactive.Linq.IQbservable<TSource> source) { }
         public static System.Reactive.Linq.IQbservable<TSource> AsQbservable<TSource>(this System.IObservable<TSource> source) { }
-        public static System.Reactive.Linq.IQbservable<TSource> AutoConnect<TSource>(this System.Reactive.Linq.IQbservableProvider provider, System.Reactive.Subjects.IConnectableObservable<TSource> source, int minObservers, System.Action<System.IDisposable> onConnect) { }
+        public static System.Reactive.Linq.IQbservable<TSource> AutoConnect<TSource>(this System.Reactive.Linq.IQbservableProvider provider, System.Reactive.Subjects.IConnectableObservable<TSource> source, int minObservers, System.Linq.Expressions.Expression<System.Action<System.IDisposable>> onConnect) { }
         public static System.Reactive.Linq.IQbservable<decimal> Average(this System.Reactive.Linq.IQbservable<decimal> source) { }
         public static System.Reactive.Linq.IQbservable<double> Average(this System.Reactive.Linq.IQbservable<double> source) { }
         public static System.Reactive.Linq.IQbservable<double> Average(this System.Reactive.Linq.IQbservable<int> source) { }
@@ -1894,6 +1894,8 @@ namespace System.Reactive.Linq
         public static System.Reactive.Linq.IQbservable<float> Max(this System.Reactive.Linq.IQbservable<float> source) { }
         public static System.Reactive.Linq.IQbservable<TSource> Max<TSource>(this System.Reactive.Linq.IQbservable<TSource> source) { }
         public static System.Reactive.Linq.IQbservable<TSource> Max<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Collections.Generic.IComparer<TSource> comparer) { }
+        public static System.Reactive.Linq.IQbservable<double> Max<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, double>> selector) { }
+        public static System.Reactive.Linq.IQbservable<float> Max<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, float>> selector) { }
         public static System.Reactive.Linq.IQbservable<decimal> Max<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, decimal>> selector) { }
         public static System.Reactive.Linq.IQbservable<int> Max<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, int>> selector) { }
         public static System.Reactive.Linq.IQbservable<long> Max<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, long>> selector) { }
@@ -1902,8 +1904,6 @@ namespace System.Reactive.Linq
         public static System.Reactive.Linq.IQbservable<System.Nullable<decimal>> Max<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, System.Nullable<decimal>>> selector) { }
         public static System.Reactive.Linq.IQbservable<System.Nullable<int>> Max<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, System.Nullable<int>>> selector) { }
         public static System.Reactive.Linq.IQbservable<System.Nullable<long>> Max<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, System.Nullable<long>>> selector) { }
-        public static System.Reactive.Linq.IQbservable<double> Max<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, double>> selector) { }
-        public static System.Reactive.Linq.IQbservable<float> Max<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, float>> selector) { }
         public static System.Reactive.Linq.IQbservable<TResult> Max<TSource, TResult>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, TResult>> selector) { }
         public static System.Reactive.Linq.IQbservable<TResult> Max<TSource, TResult>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, TResult>> selector, System.Collections.Generic.IComparer<TResult> comparer) { }
         public static System.Reactive.Linq.IQbservable<System.Collections.Generic.IList<TSource>> MaxBy<TSource, TKey>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, TKey>> keySelector) { }
@@ -1911,10 +1911,10 @@ namespace System.Reactive.Linq
         public static System.Reactive.Linq.IQbservable<TSource> Merge<TSource>(this System.Reactive.Linq.IQbservable<TSource> first, System.IObservable<TSource> second) { }
         public static System.Reactive.Linq.IQbservable<TSource> Merge<TSource>(this System.Reactive.Linq.IQbservable<TSource> first, System.IObservable<TSource> second, System.Reactive.Concurrency.IScheduler scheduler) { }
         public static System.Reactive.Linq.IQbservable<TSource> Merge<TSource>(this System.Reactive.Linq.IQbservableProvider provider, System.Reactive.Concurrency.IScheduler scheduler, params System.IObservable<>[] sources) { }
-        public static System.Reactive.Linq.IQbservable<TSource> Merge<TSource>(this System.Reactive.Linq.IQbservableProvider provider, System.Collections.Generic.IEnumerable<System.IObservable<TSource>> sources) { }
         public static System.Reactive.Linq.IQbservable<TSource> Merge<TSource>(this System.Reactive.Linq.IQbservable<System.IObservable<TSource>> sources) { }
         public static System.Reactive.Linq.IQbservable<TSource> Merge<TSource>(this System.Reactive.Linq.IQbservable<System.Threading.Tasks.Task<TSource>> sources) { }
         public static System.Reactive.Linq.IQbservable<TSource> Merge<TSource>(this System.Reactive.Linq.IQbservableProvider provider, params System.IObservable<>[] sources) { }
+        public static System.Reactive.Linq.IQbservable<TSource> Merge<TSource>(this System.Reactive.Linq.IQbservableProvider provider, System.Collections.Generic.IEnumerable<System.IObservable<TSource>> sources) { }
         public static System.Reactive.Linq.IQbservable<TSource> Merge<TSource>(this System.Reactive.Linq.IQbservable<System.IObservable<TSource>> sources, int maxConcurrent) { }
         public static System.Reactive.Linq.IQbservable<TSource> Merge<TSource>(this System.Reactive.Linq.IQbservableProvider provider, System.Collections.Generic.IEnumerable<System.IObservable<TSource>> sources, int maxConcurrent) { }
         public static System.Reactive.Linq.IQbservable<TSource> Merge<TSource>(this System.Reactive.Linq.IQbservableProvider provider, System.Collections.Generic.IEnumerable<System.IObservable<TSource>> sources, int maxConcurrent, System.Reactive.Concurrency.IScheduler scheduler) { }
@@ -1978,7 +1978,7 @@ namespace System.Reactive.Linq
         public static System.Reactive.Linq.IQbservable<TResult> Replay<TSource, TResult>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<System.IObservable<TSource>, System.IObservable<TResult>>> selector, System.TimeSpan window, System.Reactive.Concurrency.IScheduler scheduler) { }
         public static System.Reactive.Linq.IQbservable<TSource> Retry<TSource>(this System.Reactive.Linq.IQbservable<TSource> source) { }
         public static System.Reactive.Linq.IQbservable<TSource> Retry<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, int retryCount) { }
-        public static System.IObservable<TSource> RetryWhen<TSource, TSignal>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<System.IObservable<System.Exception>, System.IObservable<TSignal>>> handler) { }
+        public static System.Reactive.Linq.IQbservable<TSource> RetryWhen<TSource, TSignal>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<System.IObservable<System.Exception>, System.IObservable<TSignal>>> handler) { }
         public static System.Reactive.Linq.IQbservable<TResult> Return<TResult>(this System.Reactive.Linq.IQbservableProvider provider, TResult value) { }
         public static System.Reactive.Linq.IQbservable<TResult> Return<TResult>(this System.Reactive.Linq.IQbservableProvider provider, TResult value, System.Reactive.Concurrency.IScheduler scheduler) { }
         public static System.Reactive.Linq.IQbservable<TSource> Sample<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.TimeSpan interval) { }
@@ -1988,21 +1988,21 @@ namespace System.Reactive.Linq
         public static System.Reactive.Linq.IQbservable<TAccumulate> Scan<TSource, TAccumulate>(this System.Reactive.Linq.IQbservable<TSource> source, TAccumulate seed, System.Linq.Expressions.Expression<System.Func<TAccumulate, TSource, TAccumulate>> accumulator) { }
         public static System.Reactive.Linq.IQbservable<TResult> Select<TSource, TResult>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, TResult>> selector) { }
         public static System.Reactive.Linq.IQbservable<TResult> Select<TSource, TResult>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, int, TResult>> selector) { }
-        public static System.Reactive.Linq.IQbservable<TResult> SelectMany<TSource, TCollection, TResult>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, System.Collections.Generic.IEnumerable<TCollection>>> collectionSelector, System.Linq.Expressions.Expression<System.Func<TSource, TCollection, TResult>> resultSelector) { }
-        public static System.Reactive.Linq.IQbservable<TResult> SelectMany<TSource, TCollection, TResult>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, int, System.Collections.Generic.IEnumerable<TCollection>>> collectionSelector, System.Linq.Expressions.Expression<System.Func<TSource, int, TCollection, int, TResult>> resultSelector) { }
         public static System.Reactive.Linq.IQbservable<TResult> SelectMany<TSource, TCollection, TResult>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, System.IObservable<TCollection>>> collectionSelector, System.Linq.Expressions.Expression<System.Func<TSource, TCollection, TResult>> resultSelector) { }
         public static System.Reactive.Linq.IQbservable<TResult> SelectMany<TSource, TCollection, TResult>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, int, System.IObservable<TCollection>>> collectionSelector, System.Linq.Expressions.Expression<System.Func<TSource, int, TCollection, int, TResult>> resultSelector) { }
+        public static System.Reactive.Linq.IQbservable<TResult> SelectMany<TSource, TCollection, TResult>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, System.Collections.Generic.IEnumerable<TCollection>>> collectionSelector, System.Linq.Expressions.Expression<System.Func<TSource, TCollection, TResult>> resultSelector) { }
+        public static System.Reactive.Linq.IQbservable<TResult> SelectMany<TSource, TCollection, TResult>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, int, System.Collections.Generic.IEnumerable<TCollection>>> collectionSelector, System.Linq.Expressions.Expression<System.Func<TSource, int, TCollection, int, TResult>> resultSelector) { }
         public static System.Reactive.Linq.IQbservable<TOther> SelectMany<TSource, TOther>(this System.Reactive.Linq.IQbservable<TSource> source, System.IObservable<TOther> other) { }
         public static System.Reactive.Linq.IQbservable<TResult> SelectMany<TSource, TResult>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, System.IObservable<TResult>>> onNext, System.Linq.Expressions.Expression<System.Func<System.Exception, System.IObservable<TResult>>> onError, System.Linq.Expressions.Expression<System.Func<System.IObservable<TResult>>> onCompleted) { }
         public static System.Reactive.Linq.IQbservable<TResult> SelectMany<TSource, TResult>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, int, System.IObservable<TResult>>> onNext, System.Linq.Expressions.Expression<System.Func<System.Exception, System.IObservable<TResult>>> onError, System.Linq.Expressions.Expression<System.Func<System.IObservable<TResult>>> onCompleted) { }
-        public static System.Reactive.Linq.IQbservable<TResult> SelectMany<TSource, TResult>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, System.Collections.Generic.IEnumerable<TResult>>> selector) { }
-        public static System.Reactive.Linq.IQbservable<TResult> SelectMany<TSource, TResult>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, int, System.Collections.Generic.IEnumerable<TResult>>> selector) { }
         public static System.Reactive.Linq.IQbservable<TResult> SelectMany<TSource, TResult>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, System.IObservable<TResult>>> selector) { }
         public static System.Reactive.Linq.IQbservable<TResult> SelectMany<TSource, TResult>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, int, System.IObservable<TResult>>> selector) { }
         public static System.Reactive.Linq.IQbservable<TResult> SelectMany<TSource, TResult>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, System.Threading.Tasks.Task<TResult>>> selector) { }
         public static System.Reactive.Linq.IQbservable<TResult> SelectMany<TSource, TResult>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, int, System.Threading.Tasks.Task<TResult>>> selector) { }
         public static System.Reactive.Linq.IQbservable<TResult> SelectMany<TSource, TResult>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, System.Threading.CancellationToken, System.Threading.Tasks.Task<TResult>>> selector) { }
         public static System.Reactive.Linq.IQbservable<TResult> SelectMany<TSource, TResult>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, int, System.Threading.CancellationToken, System.Threading.Tasks.Task<TResult>>> selector) { }
+        public static System.Reactive.Linq.IQbservable<TResult> SelectMany<TSource, TResult>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, System.Collections.Generic.IEnumerable<TResult>>> selector) { }
+        public static System.Reactive.Linq.IQbservable<TResult> SelectMany<TSource, TResult>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, int, System.Collections.Generic.IEnumerable<TResult>>> selector) { }
         public static System.Reactive.Linq.IQbservable<TResult> SelectMany<TSource, TTaskResult, TResult>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, System.Threading.Tasks.Task<TTaskResult>>> taskSelector, System.Linq.Expressions.Expression<System.Func<TSource, TTaskResult, TResult>> resultSelector) { }
         public static System.Reactive.Linq.IQbservable<TResult> SelectMany<TSource, TTaskResult, TResult>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, int, System.Threading.Tasks.Task<TTaskResult>>> taskSelector, System.Linq.Expressions.Expression<System.Func<TSource, int, TTaskResult, TResult>> resultSelector) { }
         public static System.Reactive.Linq.IQbservable<TResult> SelectMany<TSource, TTaskResult, TResult>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, System.Threading.CancellationToken, System.Threading.Tasks.Task<TTaskResult>>> taskSelector, System.Linq.Expressions.Expression<System.Func<TSource, TTaskResult, TResult>> resultSelector) { }
@@ -2054,16 +2054,16 @@ namespace System.Reactive.Linq
         public static System.Reactive.Linq.IQbservable<System.Nullable<long>> Sum(this System.Reactive.Linq.IQbservable<System.Nullable<long>> source) { }
         public static System.Reactive.Linq.IQbservable<System.Nullable<float>> Sum(this System.Reactive.Linq.IQbservable<System.Nullable<float>> source) { }
         public static System.Reactive.Linq.IQbservable<float> Sum(this System.Reactive.Linq.IQbservable<float> source) { }
-        public static System.Reactive.Linq.IQbservable<System.Nullable<double>> Sum<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, System.Nullable<double>>> selector) { }
-        public static System.Reactive.Linq.IQbservable<System.Nullable<float>> Sum<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, System.Nullable<float>>> selector) { }
-        public static System.Reactive.Linq.IQbservable<System.Nullable<decimal>> Sum<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, System.Nullable<decimal>>> selector) { }
-        public static System.Reactive.Linq.IQbservable<System.Nullable<int>> Sum<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, System.Nullable<int>>> selector) { }
-        public static System.Reactive.Linq.IQbservable<System.Nullable<long>> Sum<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, System.Nullable<long>>> selector) { }
         public static System.Reactive.Linq.IQbservable<double> Sum<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, double>> selector) { }
         public static System.Reactive.Linq.IQbservable<float> Sum<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, float>> selector) { }
         public static System.Reactive.Linq.IQbservable<decimal> Sum<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, decimal>> selector) { }
         public static System.Reactive.Linq.IQbservable<int> Sum<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, int>> selector) { }
         public static System.Reactive.Linq.IQbservable<long> Sum<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, long>> selector) { }
+        public static System.Reactive.Linq.IQbservable<System.Nullable<double>> Sum<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, System.Nullable<double>>> selector) { }
+        public static System.Reactive.Linq.IQbservable<System.Nullable<float>> Sum<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, System.Nullable<float>>> selector) { }
+        public static System.Reactive.Linq.IQbservable<System.Nullable<decimal>> Sum<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, System.Nullable<decimal>>> selector) { }
+        public static System.Reactive.Linq.IQbservable<System.Nullable<int>> Sum<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, System.Nullable<int>>> selector) { }
+        public static System.Reactive.Linq.IQbservable<System.Nullable<long>> Sum<TSource>(this System.Reactive.Linq.IQbservable<TSource> source, System.Linq.Expressions.Expression<System.Func<TSource, System.Nullable<long>>> selector) { }
         public static System.Reactive.Linq.IQbservable<TSource> Switch<TSource>(this System.Reactive.Linq.IQbservable<System.IObservable<TSource>> sources) { }
         public static System.Reactive.Linq.IQbservable<TSource> Switch<TSource>(this System.Reactive.Linq.IQbservable<System.Threading.Tasks.Task<TSource>> sources) { }
         public static System.Reactive.Linq.IQbservable<TSource> Synchronize<TSource>(this System.Reactive.Linq.IQbservable<TSource> source) { }

Rx.NET/tools/HomoIcon/Program.cs

@@ -1,5 +1,6 @@
 using System;
 using System.Collections.Generic;
+using System.Globalization;
 using System.IO;
 using System.Linq;
 using System.Linq.Expressions;
@@ -19,40 +20,38 @@ namespace HomoIconize
 
             var uri = new Uri(Assembly.GetEntryAssembly().CodeBase);
 
-            var root = Path.Combine(Path.GetDirectoryName(uri.LocalPath), @"..\..\..\..\Source");
+            var root = Path.Combine(Path.GetDirectoryName(uri.LocalPath), @"..\..\..\..\Source\src");
             if (!Directory.Exists(root))
             {
                 Console.WriteLine("Error:  Could not find directory \"" + root + "\"");
                 return;
             }
 
-            Process(root, 
-                "System.Reactive.Linq", 
-                "System.Reactive.Providers", 
-                @"Reactive\Linq\Qbservable.Generated.cs", 
-                "System.Reactive.Linq.Observable", "Qbservable", true);
+            Process(root,
+                "System.Reactive", 
+                @"System.Reactive\Linq\Qbservable.Generated.cs", 
+                "System.Reactive.Linq.Observable", "Qbservable",
+                includeAsync: true, exludeFromCodeCoverage:true);
             Console.WriteLine();
 
             Process(root, 
-                "System.Reactive.Experimental", 
-                "System.Reactive.Experimental", 
-                @"Reactive\Linq\QbservableEx.Generated.cs", 
+                "System.Reactive", 
+                @"System.Reactive\Linq\QbservableEx.Generated.cs", 
                 "System.Reactive.Linq.ObservableEx", "QbservableEx");            
             Console.WriteLine();
 
             Process(root, 
-                "System.Reactive.Observable.Aliases", 
-                "System.Reactive.Observable.Aliases", 
-                "Qbservable.Aliases.Generated.cs",
+                "System.Reactive.Observable.Aliases",
+                @"System.Reactive.Observable.Aliases\Qbservable.Aliases.Generated.cs",
                 "System.Reactive.Observable.Aliases.QueryLanguage", "QbservableAliases",
-                includeAsync: false, createAliases: true);
+                includeAsync: false, createAliases: true, exludeFromCodeCoverage: true);
             Console.WriteLine();
 
             Console.WriteLine("Processing complete, press enter to continue.");
             Console.ReadLine();
         }
 
-        static void Process(string root, string sourceAssembly, string targetAssembly, string targetFile, string sourceTypeName, string targetTypeName, bool includeAsync = false, bool createAliases = false)
+        static void Process(string root, string sourceAssembly, string targetFile, string sourceTypeName, string targetTypeName, bool includeAsync = false, bool createAliases = false, bool exludeFromCodeCoverage = false)
         {
             var rxRoot = Path.Combine(root, sourceAssembly);
             if (!Directory.Exists(rxRoot))
@@ -61,35 +60,28 @@ namespace HomoIconize
                 return;
             }
 
-            var qbRoot = Path.Combine(root, targetAssembly);
-            if (!Directory.Exists(qbRoot))
-            {
-                Console.WriteLine("Error:  Could not find directory \"" + qbRoot + "\"");
-                return;
-            }
-
-            var dll = Path.Combine(rxRoot, @"..\bin\debug40\" + sourceAssembly + ".dll");
+            var dll = Path.Combine(rxRoot, @"bin\debug\netstandard2.0\" + sourceAssembly + ".dll");
             if (!File.Exists(dll))
             {
                 Console.WriteLine("Error:  Could not find file \"" + dll + "\"");
                 return;
             }
 
-            var xml = Path.Combine(rxRoot, @"..\bin\debug40\" + sourceAssembly + ".xml");
+            var xml = Path.Combine(rxRoot, @"bin\debug\netstandard2.0\" + sourceAssembly + ".xml");
             if (!File.Exists(xml))
             {
                 Console.WriteLine("Error:  Could not find file \"" + xml + "\"");
                 return;
             }
 
-            var qbsgen = Path.Combine(qbRoot, targetFile);
+            var qbsgen = Path.Combine(root, targetFile);
             if (!File.Exists(qbsgen))
             {
                 Console.WriteLine("Error:  Could not find file \"" + qbsgen + "\"");
                 return;
             }
 
-            Generate(dll, xml, qbsgen, sourceTypeName, targetTypeName, includeAsync, createAliases);
+            Generate(dll, xml, qbsgen, sourceTypeName, targetTypeName, includeAsync, createAliases, exludeFromCodeCoverage);
         }
 
         // Prototype interface to break dependencies. Only used for ToString2 ultimately.
@@ -97,7 +89,7 @@ namespace HomoIconize
         {
         }
 
-        static void Generate(string input, string xml, string output, string sourceTypeName, string targetTypeName, bool includeAsync, bool createAliases)
+        static void Generate(string input, string xml, string output, string sourceTypeName, string targetTypeName, bool includeAsync, bool createAliases, bool exludeFromCodeCoverage)
         {
             var docs = XDocument.Load(xml).Root.Element("members").Elements("member").ToDictionary(m => m.Attribute("name").Value, m => m);
 
@@ -105,7 +97,7 @@ namespace HomoIconize
 
             var asm = Assembly.LoadFrom(input);
             var t = asm.GetType(sourceTypeName);
-            _qbs = typeof(IQbservable<>); //asm.GetType("System.Reactive.Linq.IQbservable`1");
+            _qbs = typeof(IQbservable<>); 
 
             Console.WriteLine("Checking {0}...", output);
             var attr = File.GetAttributes(output);
@@ -145,45 +137,42 @@ namespace HomoIconize
             {
                 using (Out = new StreamWriter(fs))
                 {
-                    Generate(t, docs, targetTypeName, includeAsync, createAliases);
+                    Generate(t, docs, targetTypeName, includeAsync, createAliases, exludeFromCodeCoverage);
                 }
             }
         }
 
         static Type _qbs;
 
-        static void Generate(Type t, IDictionary<string, XElement> docs, string typeName, bool includeAsync, bool createAliases)
+        static void Generate(Type t, IDictionary<string, XElement> docs, string typeName, bool includeAsync, bool createAliases, bool exludeFromCodeCoverage)
         {
             WriteLine(
 @"/*
- * WARNING: Auto-generated file (" + DateTime.Now + @")
+ * WARNING: Auto-generated file (" + DateTime.Now.ToString(CultureInfo.InvariantCulture) + @")
  * Run Rx's auto-homoiconizer tool to generate this file (in the HomoIcon directory).
  */
 ");
             WriteLine(
 @"#pragma warning disable 1591
-");
-            WriteLine(
-@"#if !NO_EXPRESSIONS
 ");
 
             WriteLine(
 @"using System;
 using System.Reactive.Concurrency;
-using System.Collections.Generic;
-using System.Reactive.Joins;
+using System.Collections.Generic;");
+
+            if (exludeFromCodeCoverage)
+                WriteLine("using System.Diagnostics.CodeAnalysis;");
+
+            WriteLine(
+@"using System.Reactive.Joins;
 using System.Linq;
 using System.Linq.Expressions;
 using System.Reflection;
 using System.Threading;
+using System.Threading.Tasks;
 using System.Reactive;
 using System.Reactive.Subjects;
-#if !NO_TPL
-using System.Threading.Tasks;
-#endif
-#if !NO_REMOTING
-using System.Runtime.Remoting.Lifetime;
-#endif
 ");
             WriteLine(
 @"namespace System.Reactive.Linq
@@ -191,13 +180,16 @@ using System.Runtime.Remoting.Lifetime;
 
             Indent();
 
+            if (exludeFromCodeCoverage)
+                WriteLine("[ExcludeFromCodeCoverage]");
+
             WriteLine(
 @"public static partial class " + typeName + @"
 {");
 
             Indent();
 
-            var except = new[] { "ToAsync", "FromAsyncPattern", "And", "Then", "GetEnumerator", "get_Provider", "Wait", "ForEach", "ForEachAsync", "GetAwaiter", "First", "FirstOrDefault", "Last", "LastOrDefault", "Single", "SingleOrDefault", "Subscribe", "AsQbservable", "AsObservable", "ToEvent", "ToEventPattern" };
+            var except = new[] { "ToAsync", "FromAsyncPattern", "And", "Then", "GetEnumerator", "get_Provider", "Wait", "ForEach", "ForEachAsync", "GetAwaiter", "RunAsync", "First", "FirstOrDefault", "Last", "LastOrDefault", "Single", "SingleOrDefault", "Subscribe", "AsQbservable", "AsObservable", "ToEvent", "ToEventPattern" };
 
             foreach (var m in t.GetMethods(BindingFlags.Public | BindingFlags.Static).OrderBy(m => m.Name).ThenBy(m => !m.IsGenericMethod ? "" : string.Join(",", m.GetGenericArguments().Select(p => p.Name))).ThenBy(m => string.Join(",", m.GetParameters().Select(p => p.Name + ":" + p.ParameterType.FullName))).Where(m => !except.Contains(m.Name)))
             {
@@ -222,10 +214,6 @@ using System.Runtime.Remoting.Lifetime;
                             where ptgtd.GetGenericArguments().Count() > 5
                             select pi;
 
-                //var isLargeArity = funky.Any();
-
-                var hasTask = p.Any(pa => ContainsTask(pa.ParameterType));
-
                 var ret = m.ReturnType;
                 if (ret.IsGenericType)
                 {
@@ -341,53 +329,26 @@ using System.Runtime.Remoting.Lifetime;
                     WriteLine("#if !MONO", true);
                     poundIf = true;
                 }
-                if (isCreateAsync || hasTask)
-                {
-                    WriteLine("#if !NO_TPL", true);
-                    poundIf = true;
-                }
-                //if (name == "Remotable")
-                //{
-                //    WriteLine("#if DESKTOPCLR", true);
-                //    poundIf = true;
-                //    if (nulls.Contains("lease"))
-                //        nulls.Remove("lease");
-                //}
-                //if (isLargeArity)
-                //{
-                //    WriteLine("#if !NO_LARGEARITY", true);
-                //}
-
-                var isFep = m.Name == "FromEventPattern";
-                var isGenFep = isFep && m.GetGenericArguments().Any(a => a.Name == "TEventArgs");
-                var isNonGenFep = isFep && !isGenFep;
-
-                for (var r = 0; r < (isNonGenFep ? 2 : 1); r++)
+
                 {
                     var retStr = ret.ToString2();
 
-                    if (isNonGenFep)
-                    {
-                        if (r == 0)
-                        {
-                            WriteLine("#if !NO_EVENTARGS_CONSTRAINT", true);
-                        }
-                        else if (r == 1)
-                        {
-                            WriteLine("#else", true);
-                            retStr = retStr.Replace("EventPattern<EventArgs>", "EventPattern<object>");
-                        }
-                    }
-
                     if (xmlDoc != null)
                     {
+                        SimplifyCrefAttribute(xmlDoc);
+
                         foreach (var docLine in xmlDoc.Element("summary").ToString().Split('\n'))
                             WriteLine("/// " + docLine.TrimStart().TrimEnd('\r'));
 
                         if (hasProvider)
-                            WriteLine("/// <param name=\"provider\">Query provider used to construct the IQbservable&lt;T&gt; data source.</param>");
+                            WriteLine("/// <param name=\"provider\">Query provider used to construct the <see cref=\"IQbservable{T}\"/> data source.</param>");
 
-                        foreach (var docLine in xmlDoc.Elements().Where(e => e.Name != "summary").SelectMany(e => e.ToString().Split('\n')))
+                        var rest = xmlDoc
+                            .Elements()
+                            .Where(e => e.Name != "summary")
+                            .SelectMany(e => e.ToString().Split('\n'));
+
+                        foreach (var docLine in rest)
                             WriteLine("/// " + docLine.TrimStart().TrimEnd('\r'));
 
                         if (requiresQueryProvider)
@@ -401,28 +362,18 @@ using System.Runtime.Remoting.Lifetime;
                         WriteLine("[Obsolete(\"" + obsolete.Message + "\")]");
 
                     WriteLine("public static " + retStr + " " + name + g + "(" + string.Join(", ", pars) + ")");
-                    if (isGenFep)
+
+                    var genCons = (from a in m.GetGenericArguments()
+                                   from c in a.GetGenericParameterConstraints()
+                                   select new { a, c })
+                                  .ToList();
+
+                    if (genCons.Count > 0)
                     {
-                        WriteLine("#if !NO_EVENTARGS_CONSTRAINT", true);
                         Indent();
-                        WriteLine("where TEventArgs : EventArgs");
+                        foreach (var gc in genCons)
+                            WriteLine("where " + gc.a.Name + " : " + gc.c.Name);
                         Outdent();
-                        WriteLine("#endif", true);
-                    }
-                    else
-                    {
-                        var genCons = (from a in m.GetGenericArguments()
-                                       from c in a.GetGenericParameterConstraints()
-                                       select new { a, c })
-                                      .ToList();
-
-                        if (genCons.Count > 0)
-                        {
-                            Indent();
-                            foreach (var gc in genCons)
-                                WriteLine("where " + gc.a.Name + " : " + gc.c.Name);
-                            Outdent();
-                        }
                     }
 
                     if (createAliases)
@@ -431,13 +382,13 @@ using System.Runtime.Remoting.Lifetime;
 
                         switch (name)
                         {
-                            case "Map": 
+                            case "Map":
                                 underlying = "Select";
                                 break;
                             case "FlatMap":
                                 underlying = "SelectMany";
                                 break;
-                            case "Filter": 
+                            case "Filter":
                                 underlying = "Where";
                                 break;
                         }
@@ -447,6 +398,7 @@ using System.Runtime.Remoting.Lifetime;
                         WriteLine("return Qbservable." + underlying + g + "(" + string.Join(", ", parNames) + ");");
                         Outdent();
                         WriteLine("}");
+                        WriteLine("");
                         continue;
                     }
 
@@ -456,16 +408,12 @@ using System.Runtime.Remoting.Lifetime;
                     {
                         WriteLine("if (" + n + " == null)");
                         Indent();
-                        WriteLine("throw new ArgumentNullException(\"" + n + "\");");
+                        WriteLine("throw new ArgumentNullException(nameof(" + n + "));");
                         Outdent();
                     }
                     WriteLine("");
 
                     var gArg = ret.GetGenericArguments().Single().ToString2();
-                    if (isNonGenFep && r == 1)
-                    {
-                        gArg = gArg.Replace("EventPattern<EventArgs>", "EventPattern<object>");
-                    }
 
                     WriteLine("return " + factory + ".CreateQuery<" + gArg + ">(");
                     Indent();
@@ -490,16 +438,12 @@ using System.Runtime.Remoting.Lifetime;
                     Outdent();
                     WriteLine("}");
 
-                    if (isNonGenFep && r == 1)
-                        WriteLine("#endif", true);
                 }
 
                 if (poundIf)
                     WriteLine("#endif", true);
                 if (isExp)
                     WriteLine("#endif", true);
-                //if (isLargeArity)
-                //    WriteLine("#endif", true);
                 WriteLine("");
             }
 
@@ -517,9 +461,6 @@ using System.Runtime.Remoting.Lifetime;
 
             WriteLine(
 @"}
-");
-            WriteLine(
-@"#endif
 ");
             WriteLine(
 @"#pragma warning restore 1591
@@ -527,6 +468,38 @@ using System.Runtime.Remoting.Lifetime;
 
         }
 
+        private static void SimplifyCrefAttribute(XElement parent)
+        {
+            foreach (var element in parent.Descendants())
+            {
+                var att = element.Attribute("cref");
+                if (att != null)
+                {
+                    element.Attribute("cref").SetValue(SimplyfyDocType(att.Value as string));
+                }
+            }
+        }
+
+        private static string SimplyfyDocType(string cref)
+        {
+            var v = cref.Replace("T:System.", "")
+                 .Replace("F:System.", "");
+            switch (v)
+            {
+                case "Double": return "double";
+                // case "Decimal": return "decimal";
+                case "Int32": return "int";
+                case "Inte16": return "short";
+                case "Int64": return "long";
+                // case "Single": return "float";
+                case "IObservable`1": return "IObservable{T}";
+            }
+
+            if (v.Contains(".") || v.Contains("`"))
+                return cref;
+            return v;
+        }
+
         static bool ContainsTask(Type t)
         {
             if (t == typeof(Task))
@@ -552,9 +525,6 @@ using System.Runtime.Remoting.Lifetime;
             {
                 for (int i = 0; i <= 16; i++)
                 {
-                    //if (i == 5)
-                    //    WriteLine("#if !NO_LARGEARITY", true);
-
                     foreach (var withScheduler in new[] { false, true })
                     {
                         var genArgs = default(string[]);
@@ -564,11 +534,6 @@ using System.Runtime.Remoting.Lifetime;
                             genArgs = new string[0];
                             lamPars = new string[0];
                         }
-                        //else if (i == 1)
-                        //{
-                        //    genArgs = new[] { "TSource" };
-                        //    lamPars = new[] { "t" };
-                        //}
                         else
                         {
                             genArgs = Enumerable.Range(1, i).Select(j => "TArg" + j).ToArray();
@@ -607,10 +572,12 @@ using System.Runtime.Remoting.Lifetime;
 
                         if (xmlDoc != null)
                         {
+                            SimplifyCrefAttribute(xmlDoc);
+
                             foreach (var docLine in xmlDoc.Element("summary").ToString().Split('\n'))
                                 WriteLine("/// " + docLine.TrimStart().TrimEnd('\r'));
 
-                            WriteLine("/// <param name=\"provider\">Query provider used to construct the IQbservable&lt;T&gt; data source.</param>");
+                            WriteLine("/// <param name=\"provider\">Query provider used to construct the <see cref=\"IQbservable{T}\"/> data source.</param>");
 
                             foreach (var docLine in xmlDoc.Elements().Where(e => e.Name != "summary").SelectMany(e => e.ToString().Split('\n')))
                                 WriteLine("/// " + docLine.TrimStart().TrimEnd('\r'));
@@ -623,19 +590,19 @@ using System.Runtime.Remoting.Lifetime;
 
                         WriteLine("if (provider == null)");
                         Indent();
-                        WriteLine("throw new ArgumentNullException(\"provider\");");
+                        WriteLine("throw new ArgumentNullException(nameof(provider));");
                         Outdent();
 
                         WriteLine("if (" + fParam + " == null)");
                         Indent();
-                        WriteLine("throw new ArgumentNullException(\"" + fParam + "\");");
+                        WriteLine("throw new ArgumentNullException(nameof(" + fParam + "));");
                         Outdent();
 
                         if (withScheduler)
                         {
                             WriteLine("if (scheduler == null)");
                             Indent();
-                            WriteLine("throw new ArgumentNullException(\"scheduler\");");
+                            WriteLine("throw new ArgumentNullException(nameof(scheduler));");
                             Outdent();
                         }
 
@@ -682,9 +649,6 @@ using System.Runtime.Remoting.Lifetime;
                         WriteLine("}");
                         WriteLine("");
                     }
-
-                    //if (i == 16)
-                    //    WriteLine("#endif", true);
                 }
             }
 
@@ -694,9 +658,6 @@ using System.Runtime.Remoting.Lifetime;
             {
                 for (int i = 0; i < 15; i++)
                 {
-                    //if (i == 3)
-                    //    WriteLine("#if !NO_LARGEARITY", true);
-
                     var genArgs = default(string[]);
                     var lamPars = default(string[]);
                     if (i == 0)
@@ -749,10 +710,11 @@ using System.Runtime.Remoting.Lifetime;
 
                     if (xmlDoc != null)
                     {
+                        SimplifyCrefAttribute(xmlDoc);
                         foreach (var docLine in xmlDoc.Element("summary").ToString().Split('\n'))
                             WriteLine("/// " + docLine.TrimStart().TrimEnd('\r'));
 
-                        WriteLine("/// <param name=\"provider\">Query provider used to construct the IQbservable&lt;T&gt; data source.</param>");
+                        WriteLine("/// <param name=\"provider\">Query provider used to construct the <see cref=\"IQbservable{T}\"/> data source.</param>");
 
                         foreach (var docLine in xmlDoc.Elements().Where(e => e.Name != "summary").SelectMany(e => e.ToString().Split('\n')))
                             WriteLine("/// " + docLine.TrimStart().TrimEnd('\r'));
@@ -769,17 +731,17 @@ using System.Runtime.Remoting.Lifetime;
 
                     WriteLine("if (provider == null)");
                     Indent();
-                    WriteLine("throw new ArgumentNullException(\"provider\");");
+                    WriteLine("throw new ArgumentNullException(nameof(provider));");
                     Outdent();
 
                     WriteLine("if (begin == null)");
                     Indent();
-                    WriteLine("throw new ArgumentNullException(\"begin\");");
+                    WriteLine("throw new ArgumentNullException(nameof(begin));");
                     Outdent();
 
                     WriteLine("if (end == null)");
                     Indent();
-                    WriteLine("throw new ArgumentNullException(\"end\");");
+                    WriteLine("throw new ArgumentNullException(nameof(end));");
                     Outdent();
 
                     WriteLine("");
@@ -822,9 +784,6 @@ using System.Runtime.Remoting.Lifetime;
 
                     WriteLine("}");
                     WriteLine("");
-
-                    //if (i == 14)
-                    //    WriteLine("#endif", true);
                 }
             }
         }
@@ -835,7 +794,12 @@ using System.Runtime.Remoting.Lifetime;
         static void WriteLine(string s, bool noIndent = false)
         {
             foreach (var t in s.Split('\n'))
-                Out.WriteLine((noIndent ? "" : new string(' ', _indent * 4)) + t.TrimEnd('\r'));
+            {
+                var indentspace = noIndent || string.IsNullOrWhiteSpace(t)
+                    ? "" 
+                    : new string(' ', _indent * 4);
+                Out.WriteLine(indentspace + t.TrimEnd('\r'));
+            }
         }
 
         static void Indent()

Rx.NET/tools/HomoIcon/README.md

@@ -0,0 +1,21 @@
+The HomoIcon Tool
+=================
+
+The HomoIcon tool generates a part of the `Qbservable` implementation on the basis of the public `Observable` API.
+
+When do I use the tool?
+-----------------------
+
+Whenever an `Observable` operator is added, removed, changed or its documentation is changed, the homoicon tool
+needs to be executed to keep the `Qbservable` and the `Observable` implementation in sync.
+
+How do I use the tool?
+----------------------
+
+ 1. Apply your changes to the `Observable` API.
+ 2. Enable the XML documentation in the _System.Reactive_ and the _System.Reactive.Observable.Aliases_ project properties.
+    ![Enable XML documentation](enable-xml-documentation.gif)
+ 3. Rebuild the Rx solution.
+ 4. You should have now the dll and xml files in the `System.Reactive\bin\Debug\netstandard2.0` and `System.Reactive.Observable.Aliases\bin\Debug\netstandard2.0`
+    folders.
+ 5. Build and execute the HomoIcon tool.