using System.Collections.Generic; using System.Diagnostics.CodeAnalysis; using System.Linq; using System.Reactive.Concurrency; using System.Reactive.Joins; using System.Reactive.Subjects; using System.Runtime.CompilerServices; using System.Runtime.InteropServices; using System.Threading; using System.Threading.Tasks; namespace System.Reactive.Linq { [NullableContext(1)] internal interface IQueryLanguage { IObservable<TAccumulate> Aggregate<[Nullable(2)] TSource, [Nullable(2)] TAccumulate>(IObservable<TSource> source, TAccumulate seed, Func<TAccumulate, TSource, TAccumulate> accumulator); IObservable<TResult> Aggregate<[Nullable(2)] TSource, [Nullable(2)] TAccumulate, [Nullable(2)] TResult>(IObservable<TSource> source, TAccumulate seed, Func<TAccumulate, TSource, TAccumulate> accumulator, Func<TAccumulate, TResult> resultSelector); IObservable<TSource> Aggregate<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, TSource, TSource> accumulator); IObservable<bool> All<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, bool> predicate); IObservable<bool> Any<[Nullable(2)] TSource>(IObservable<TSource> source); IObservable<bool> Any<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, bool> predicate); IObservable<double> Average(IObservable<double> source); IObservable<float> Average(IObservable<float> source); IObservable<decimal> Average(IObservable<decimal> source); IObservable<double> Average(IObservable<int> source); IObservable<double> Average(IObservable<long> source); IObservable<double?> Average(IObservable<double?> source); IObservable<float?> Average(IObservable<float?> source); IObservable<decimal?> Average(IObservable<decimal?> source); IObservable<double?> Average(IObservable<int?> source); IObservable<double?> Average(IObservable<long?> source); IObservable<double> Average<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, double> selector); IObservable<float> Average<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, float> selector); IObservable<decimal> Average<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, decimal> selector); IObservable<double> Average<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, int> selector); IObservable<double> Average<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, long> selector); IObservable<double?> Average<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, double?> selector); IObservable<float?> Average<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, float?> selector); IObservable<decimal?> Average<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, decimal?> selector); IObservable<double?> Average<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, int?> selector); IObservable<double?> Average<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, long?> selector); IObservable<bool> Contains<[Nullable(2)] TSource>(IObservable<TSource> source, TSource value); IObservable<bool> Contains<[Nullable(2)] TSource>(IObservable<TSource> source, TSource value, IEqualityComparer<TSource> comparer); IObservable<int> Count<[Nullable(2)] TSource>(IObservable<TSource> source); IObservable<int> Count<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, bool> predicate); IObservable<TSource> ElementAt<[Nullable(2)] TSource>(IObservable<TSource> source, int index); [return: Nullable(new byte[] { 1, 2 })] IObservable<TSource> ElementAtOrDefault<[Nullable(2)] TSource>(IObservable<TSource> source, int index); IObservable<TSource> FirstAsync<[Nullable(2)] TSource>(IObservable<TSource> source); IObservable<TSource> FirstAsync<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, bool> predicate); [return: Nullable(new byte[] { 1, 2 })] IObservable<TSource> FirstOrDefaultAsync<[Nullable(2)] TSource>(IObservable<TSource> source); [return: Nullable(new byte[] { 1, 2 })] IObservable<TSource> FirstOrDefaultAsync<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, bool> predicate); IObservable<bool> IsEmpty<[Nullable(2)] TSource>(IObservable<TSource> source); IObservable<TSource> LastAsync<[Nullable(2)] TSource>(IObservable<TSource> source); IObservable<TSource> LastAsync<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, bool> predicate); [return: Nullable(new byte[] { 1, 2 })] IObservable<TSource> LastOrDefaultAsync<[Nullable(2)] TSource>(IObservable<TSource> source); [return: Nullable(new byte[] { 1, 2 })] IObservable<TSource> LastOrDefaultAsync<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, bool> predicate); IObservable<long> LongCount<[Nullable(2)] TSource>(IObservable<TSource> source); IObservable<long> LongCount<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, bool> predicate); IObservable<TSource> Max<[Nullable(2)] TSource>(IObservable<TSource> source); IObservable<TSource> Max<[Nullable(2)] TSource>(IObservable<TSource> source, IComparer<TSource> comparer); IObservable<double> Max(IObservable<double> source); IObservable<float> Max(IObservable<float> source); IObservable<decimal> Max(IObservable<decimal> source); IObservable<int> Max(IObservable<int> source); IObservable<long> Max(IObservable<long> source); IObservable<double?> Max(IObservable<double?> source); IObservable<float?> Max(IObservable<float?> source); IObservable<decimal?> Max(IObservable<decimal?> source); IObservable<int?> Max(IObservable<int?> source); IObservable<long?> Max(IObservable<long?> source); IObservable<TResult> Max<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TSource, TResult> selector); IObservable<TResult> Max<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TSource, TResult> selector, IComparer<TResult> comparer); IObservable<double> Max<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, double> selector); IObservable<float> Max<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, float> selector); IObservable<decimal> Max<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, decimal> selector); IObservable<int> Max<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, int> selector); IObservable<long> Max<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, long> selector); IObservable<double?> Max<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, double?> selector); IObservable<float?> Max<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, float?> selector); IObservable<decimal?> Max<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, decimal?> selector); IObservable<int?> Max<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, int?> selector); IObservable<long?> Max<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, long?> selector); IObservable<IList<TSource>> MaxBy<[Nullable(2)] TSource, [Nullable(2)] TKey>(IObservable<TSource> source, Func<TSource, TKey> keySelector); IObservable<IList<TSource>> MaxBy<[Nullable(2)] TSource, [Nullable(2)] TKey>(IObservable<TSource> source, Func<TSource, TKey> keySelector, IComparer<TKey> comparer); IObservable<TSource> Min<[Nullable(2)] TSource>(IObservable<TSource> source); IObservable<TSource> Min<[Nullable(2)] TSource>(IObservable<TSource> source, IComparer<TSource> comparer); IObservable<double> Min(IObservable<double> source); IObservable<float> Min(IObservable<float> source); IObservable<decimal> Min(IObservable<decimal> source); IObservable<int> Min(IObservable<int> source); IObservable<long> Min(IObservable<long> source); IObservable<double?> Min(IObservable<double?> source); IObservable<float?> Min(IObservable<float?> source); IObservable<decimal?> Min(IObservable<decimal?> source); IObservable<int?> Min(IObservable<int?> source); IObservable<long?> Min(IObservable<long?> source); IObservable<TResult> Min<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TSource, TResult> selector); IObservable<TResult> Min<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TSource, TResult> selector, IComparer<TResult> comparer); IObservable<double> Min<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, double> selector); IObservable<float> Min<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, float> selector); IObservable<decimal> Min<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, decimal> selector); IObservable<int> Min<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, int> selector); IObservable<long> Min<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, long> selector); IObservable<double?> Min<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, double?> selector); IObservable<float?> Min<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, float?> selector); IObservable<decimal?> Min<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, decimal?> selector); IObservable<int?> Min<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, int?> selector); IObservable<long?> Min<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, long?> selector); IObservable<IList<TSource>> MinBy<[Nullable(2)] TSource, [Nullable(2)] TKey>(IObservable<TSource> source, Func<TSource, TKey> keySelector); IObservable<IList<TSource>> MinBy<[Nullable(2)] TSource, [Nullable(2)] TKey>(IObservable<TSource> source, Func<TSource, TKey> keySelector, IComparer<TKey> comparer); IObservable<bool> SequenceEqual<[Nullable(2)] TSource>(IObservable<TSource> first, IObservable<TSource> second); IObservable<bool> SequenceEqual<[Nullable(2)] TSource>(IObservable<TSource> first, IObservable<TSource> second, IEqualityComparer<TSource> comparer); IObservable<bool> SequenceEqual<[Nullable(2)] TSource>(IObservable<TSource> first, IEnumerable<TSource> second); IObservable<bool> SequenceEqual<[Nullable(2)] TSource>(IObservable<TSource> first, IEnumerable<TSource> second, IEqualityComparer<TSource> comparer); IObservable<TSource> SingleAsync<[Nullable(2)] TSource>(IObservable<TSource> source); IObservable<TSource> SingleAsync<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, bool> predicate); [return: Nullable(new byte[] { 1, 2 })] IObservable<TSource> SingleOrDefaultAsync<[Nullable(2)] TSource>(IObservable<TSource> source); [return: Nullable(new byte[] { 1, 2 })] IObservable<TSource> SingleOrDefaultAsync<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, bool> predicate); IObservable<double> Sum(IObservable<double> source); IObservable<float> Sum(IObservable<float> source); IObservable<decimal> Sum(IObservable<decimal> source); IObservable<int> Sum(IObservable<int> source); IObservable<long> Sum(IObservable<long> source); IObservable<double?> Sum(IObservable<double?> source); IObservable<float?> Sum(IObservable<float?> source); IObservable<decimal?> Sum(IObservable<decimal?> source); IObservable<int?> Sum(IObservable<int?> source); IObservable<long?> Sum(IObservable<long?> source); IObservable<double> Sum<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, double> selector); IObservable<float> Sum<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, float> selector); IObservable<decimal> Sum<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, decimal> selector); IObservable<int> Sum<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, int> selector); IObservable<long> Sum<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, long> selector); IObservable<double?> Sum<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, double?> selector); IObservable<float?> Sum<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, float?> selector); IObservable<decimal?> Sum<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, decimal?> selector); IObservable<int?> Sum<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, int?> selector); IObservable<long?> Sum<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, long?> selector); IObservable<TSource[]> ToArray<[Nullable(2)] TSource>(IObservable<TSource> source); IObservable<IDictionary<TKey, TElement>> ToDictionary<[Nullable(2)] TSource, TKey, [Nullable(2)] TElement>(IObservable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, IEqualityComparer<TKey> comparer); IObservable<IDictionary<TKey, TElement>> ToDictionary<[Nullable(2)] TSource, TKey, [Nullable(2)] TElement>(IObservable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector); IObservable<IDictionary<TKey, TSource>> ToDictionary<[Nullable(2)] TSource, TKey>(IObservable<TSource> source, Func<TSource, TKey> keySelector, IEqualityComparer<TKey> comparer); IObservable<IDictionary<TKey, TSource>> ToDictionary<[Nullable(2)] TSource, TKey>(IObservable<TSource> source, Func<TSource, TKey> keySelector); IObservable<IList<TSource>> ToList<[Nullable(2)] TSource>(IObservable<TSource> source); IObservable<ILookup<TKey, TElement>> ToLookup<[Nullable(2)] TSource, [Nullable(2)] TKey, [Nullable(2)] TElement>(IObservable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, IEqualityComparer<TKey> comparer); IObservable<ILookup<TKey, TSource>> ToLookup<[Nullable(2)] TSource, [Nullable(2)] TKey>(IObservable<TSource> source, Func<TSource, TKey> keySelector, IEqualityComparer<TKey> comparer); IObservable<ILookup<TKey, TElement>> ToLookup<[Nullable(2)] TSource, [Nullable(2)] TKey, [Nullable(2)] TElement>(IObservable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector); IObservable<ILookup<TKey, TSource>> ToLookup<[Nullable(2)] TSource, [Nullable(2)] TKey>(IObservable<TSource> source, Func<TSource, TKey> keySelector); Func<IObservable<TResult>> FromAsyncPattern<[Nullable(2)] TResult>([Nullable(new byte[] { 1, 1, 2, 1 })] Func<AsyncCallback, object, IAsyncResult> begin, Func<IAsyncResult, TResult> end); Func<T1, IObservable<TResult>> FromAsyncPattern<[Nullable(2)] T1, [Nullable(2)] TResult>([Nullable(new byte[] { 1, 1, 1, 2, 1 })] Func<T1, AsyncCallback, object, IAsyncResult> begin, Func<IAsyncResult, TResult> end); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, IObservable<TResult>> FromAsyncPattern<T1, T2, TResult>([Nullable(new byte[] { 1, 1, 1, 1, 2, 1 })] Func<T1, T2, AsyncCallback, object, IAsyncResult> begin, [Nullable(1)] Func<IAsyncResult, TResult> end); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, IObservable<TResult>> FromAsyncPattern<T1, T2, T3, TResult>([Nullable(new byte[] { 1, 1, 1, 1, 1, 2, 1 })] Func<T1, T2, T3, AsyncCallback, object, IAsyncResult> begin, [Nullable(1)] Func<IAsyncResult, TResult> end); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, IObservable<TResult>> FromAsyncPattern<T1, T2, T3, T4, TResult>([Nullable(new byte[] { 1, 1, 1, 1, 1, 1, 2, 1 })] Func<T1, T2, T3, T4, AsyncCallback, object, IAsyncResult> begin, [Nullable(1)] Func<IAsyncResult, TResult> end); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, IObservable<TResult>> FromAsyncPattern<T1, T2, T3, T4, T5, TResult>([Nullable(new byte[] { 1, 1, 1, 1, 1, 1, 1, 2, 1 })] Func<T1, T2, T3, T4, T5, AsyncCallback, object, IAsyncResult> begin, [Nullable(1)] Func<IAsyncResult, TResult> end); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, IObservable<TResult>> FromAsyncPattern<T1, T2, T3, T4, T5, T6, TResult>([Nullable(new byte[] { 1, 1, 1, 1, 1, 1, 1, 1, 2, 1 })] Func<T1, T2, T3, T4, T5, T6, AsyncCallback, object, IAsyncResult> begin, [Nullable(1)] Func<IAsyncResult, TResult> end); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, IObservable<TResult>> FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, TResult>([Nullable(new byte[] { 1, 1, 1, 1, 1, 1, 1, 1, 1, 2, 1 })] Func<T1, T2, T3, T4, T5, T6, T7, AsyncCallback, object, IAsyncResult> begin, [Nullable(1)] Func<IAsyncResult, TResult> end); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, IObservable<TResult>> FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, TResult>([Nullable(new byte[] { 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 2, 1 })] Func<T1, T2, T3, T4, T5, T6, T7, T8, AsyncCallback, object, IAsyncResult> begin, [Nullable(1)] Func<IAsyncResult, TResult> end); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, IObservable<TResult>> FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult>([Nullable(new byte[] { 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 2, 1 })] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, AsyncCallback, object, IAsyncResult> begin, [Nullable(1)] Func<IAsyncResult, TResult> end); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, IObservable<TResult>> FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult>([Nullable(new byte[] { 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 2, 1 })] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, AsyncCallback, object, IAsyncResult> begin, [Nullable(1)] Func<IAsyncResult, TResult> end); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, IObservable<TResult>> FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult>([Nullable(new byte[] { 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 2, 1 })] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, AsyncCallback, object, IAsyncResult> begin, [Nullable(1)] Func<IAsyncResult, TResult> end); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, IObservable<TResult>> FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult>([Nullable(new byte[] { 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 2, 1 })] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, AsyncCallback, object, IAsyncResult> begin, [Nullable(1)] Func<IAsyncResult, TResult> end); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, IObservable<TResult>> FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult>([Nullable(new byte[] { 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 2, 1 })] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, AsyncCallback, object, IAsyncResult> begin, [Nullable(1)] Func<IAsyncResult, TResult> end); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, IObservable<TResult>> FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult>([Nullable(new byte[] { 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 2, 1 })] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, AsyncCallback, object, IAsyncResult> begin, [Nullable(1)] Func<IAsyncResult, TResult> end); Func<IObservable<Unit>> FromAsyncPattern([Nullable(new byte[] { 1, 1, 2, 1 })] Func<AsyncCallback, object, IAsyncResult> begin, Action<IAsyncResult> end); Func<T1, IObservable<Unit>> FromAsyncPattern<[Nullable(2)] T1>([Nullable(new byte[] { 1, 1, 1, 2, 1 })] Func<T1, AsyncCallback, object, IAsyncResult> begin, Action<IAsyncResult> end); Func<T1, T2, IObservable<Unit>> FromAsyncPattern<[Nullable(2)] T1, [Nullable(2)] T2>([Nullable(new byte[] { 1, 1, 1, 1, 2, 1 })] Func<T1, T2, AsyncCallback, object, IAsyncResult> begin, Action<IAsyncResult> end); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, IObservable<Unit>> FromAsyncPattern<T1, T2, T3>([Nullable(new byte[] { 1, 1, 1, 1, 1, 2, 1 })] Func<T1, T2, T3, AsyncCallback, object, IAsyncResult> begin, [Nullable(1)] Action<IAsyncResult> end); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, IObservable<Unit>> FromAsyncPattern<T1, T2, T3, T4>([Nullable(new byte[] { 1, 1, 1, 1, 1, 1, 2, 1 })] Func<T1, T2, T3, T4, AsyncCallback, object, IAsyncResult> begin, [Nullable(1)] Action<IAsyncResult> end); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, IObservable<Unit>> FromAsyncPattern<T1, T2, T3, T4, T5>([Nullable(new byte[] { 1, 1, 1, 1, 1, 1, 1, 2, 1 })] Func<T1, T2, T3, T4, T5, AsyncCallback, object, IAsyncResult> begin, [Nullable(1)] Action<IAsyncResult> end); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, IObservable<Unit>> FromAsyncPattern<T1, T2, T3, T4, T5, T6>([Nullable(new byte[] { 1, 1, 1, 1, 1, 1, 1, 1, 2, 1 })] Func<T1, T2, T3, T4, T5, T6, AsyncCallback, object, IAsyncResult> begin, [Nullable(1)] Action<IAsyncResult> end); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, IObservable<Unit>> FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7>([Nullable(new byte[] { 1, 1, 1, 1, 1, 1, 1, 1, 1, 2, 1 })] Func<T1, T2, T3, T4, T5, T6, T7, AsyncCallback, object, IAsyncResult> begin, [Nullable(1)] Action<IAsyncResult> end); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, IObservable<Unit>> FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8>([Nullable(new byte[] { 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 2, 1 })] Func<T1, T2, T3, T4, T5, T6, T7, T8, AsyncCallback, object, IAsyncResult> begin, [Nullable(1)] Action<IAsyncResult> end); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, IObservable<Unit>> FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9>([Nullable(new byte[] { 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 2, 1 })] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, AsyncCallback, object, IAsyncResult> begin, [Nullable(1)] Action<IAsyncResult> end); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, IObservable<Unit>> FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10>([Nullable(new byte[] { 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 2, 1 })] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, AsyncCallback, object, IAsyncResult> begin, [Nullable(1)] Action<IAsyncResult> end); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, IObservable<Unit>> FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11>([Nullable(new byte[] { 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 2, 1 })] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, AsyncCallback, object, IAsyncResult> begin, [Nullable(1)] Action<IAsyncResult> end); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, IObservable<Unit>> FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12>([Nullable(new byte[] { 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 2, 1 })] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, AsyncCallback, object, IAsyncResult> begin, [Nullable(1)] Action<IAsyncResult> end); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, IObservable<Unit>> FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13>([Nullable(new byte[] { 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 2, 1 })] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, AsyncCallback, object, IAsyncResult> begin, [Nullable(1)] Action<IAsyncResult> end); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, IObservable<Unit>> FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14>([Nullable(new byte[] { 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 2, 1 })] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, AsyncCallback, object, IAsyncResult> begin, [Nullable(1)] Action<IAsyncResult> end); IObservable<TSource> Start<[Nullable(2)] TSource>(Func<TSource> function); IObservable<TSource> Start<[Nullable(2)] TSource>(Func<TSource> function, IScheduler scheduler); IObservable<TSource> StartAsync<[Nullable(2)] TSource>(Func<Task<TSource>> functionAsync); IObservable<TSource> StartAsync<[Nullable(2)] TSource>(Func<CancellationToken, Task<TSource>> functionAsync); IObservable<TSource> StartAsync<[Nullable(2)] TSource>(Func<Task<TSource>> functionAsync, [In] [IsReadOnly] TaskObservationOptions.Value options); IObservable<TSource> StartAsync<[Nullable(2)] TSource>(Func<CancellationToken, Task<TSource>> functionAsync, [In] [IsReadOnly] TaskObservationOptions.Value options); IObservable<Unit> Start(Action action); IObservable<Unit> Start(Action action, IScheduler scheduler); IObservable<Unit> StartAsync(Func<Task> actionAsync); IObservable<Unit> StartAsync(Func<CancellationToken, Task> actionAsync); IObservable<Unit> StartAsync(Func<Task> actionAsync, [In] [IsReadOnly] TaskObservationOptions.Value options); IObservable<Unit> StartAsync(Func<CancellationToken, Task> actionAsync, [In] [IsReadOnly] TaskObservationOptions.Value options); IObservable<TResult> FromAsync<[Nullable(2)] TResult>(Func<Task<TResult>> functionAsync); IObservable<TResult> FromAsync<[Nullable(2)] TResult>(Func<CancellationToken, Task<TResult>> functionAsync); IObservable<Unit> FromAsync(Func<Task> actionAsync); IObservable<Unit> FromAsync(Func<CancellationToken, Task> actionAsync); IObservable<TResult> FromAsync<[Nullable(2)] TResult>(Func<Task<TResult>> functionAsync, TaskObservationOptions.Value options); IObservable<TResult> FromAsync<[Nullable(2)] TResult>(Func<CancellationToken, Task<TResult>> functionAsync, TaskObservationOptions.Value options); IObservable<Unit> FromAsync(Func<Task> actionAsync, TaskObservationOptions.Value options); IObservable<Unit> FromAsync(Func<CancellationToken, Task> actionAsync, TaskObservationOptions.Value options); Func<IObservable<TResult>> ToAsync<[Nullable(2)] TResult>(Func<TResult> function); Func<IObservable<TResult>> ToAsync<[Nullable(2)] TResult>(Func<TResult> function, IScheduler scheduler); Func<T, IObservable<TResult>> ToAsync<[Nullable(2)] T, [Nullable(2)] TResult>(Func<T, TResult> function); Func<T, IObservable<TResult>> ToAsync<[Nullable(2)] T, [Nullable(2)] TResult>(Func<T, TResult> function, IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, IObservable<TResult>> ToAsync<T1, T2, TResult>([Nullable(1)] Func<T1, T2, TResult> function); Func<T1, T2, IObservable<TResult>> ToAsync<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] TResult>(Func<T1, T2, TResult> function, IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, IObservable<TResult>> ToAsync<T1, T2, T3, TResult>([Nullable(1)] Func<T1, T2, T3, TResult> function); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, IObservable<TResult>> ToAsync<T1, T2, T3, TResult>([Nullable(1)] Func<T1, T2, T3, TResult> function, [Nullable(1)] IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, IObservable<TResult>> ToAsync<T1, T2, T3, T4, TResult>([Nullable(1)] Func<T1, T2, T3, T4, TResult> function); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, IObservable<TResult>> ToAsync<T1, T2, T3, T4, TResult>([Nullable(1)] Func<T1, T2, T3, T4, TResult> function, [Nullable(1)] IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, IObservable<TResult>> ToAsync<T1, T2, T3, T4, T5, TResult>([Nullable(1)] Func<T1, T2, T3, T4, T5, TResult> function); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, IObservable<TResult>> ToAsync<T1, T2, T3, T4, T5, TResult>([Nullable(1)] Func<T1, T2, T3, T4, T5, TResult> function, [Nullable(1)] IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, IObservable<TResult>> ToAsync<T1, T2, T3, T4, T5, T6, TResult>([Nullable(1)] Func<T1, T2, T3, T4, T5, T6, TResult> function); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, IObservable<TResult>> ToAsync<T1, T2, T3, T4, T5, T6, TResult>([Nullable(1)] Func<T1, T2, T3, T4, T5, T6, TResult> function, [Nullable(1)] IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, IObservable<TResult>> ToAsync<T1, T2, T3, T4, T5, T6, T7, TResult>([Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, TResult> function); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, IObservable<TResult>> ToAsync<T1, T2, T3, T4, T5, T6, T7, TResult>([Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, TResult> function, [Nullable(1)] IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, IObservable<TResult>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, TResult>([Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, TResult> function); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, IObservable<TResult>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, TResult>([Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, TResult> function, [Nullable(1)] IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, IObservable<TResult>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult>([Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult> function); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, IObservable<TResult>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult>([Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult> function, [Nullable(1)] IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, IObservable<TResult>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult>([Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult> function); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, IObservable<TResult>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult>([Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult> function, [Nullable(1)] IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, IObservable<TResult>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult>([Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult> function); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, IObservable<TResult>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult>([Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult> function, [Nullable(1)] IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, IObservable<TResult>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult>([Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult> function); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, IObservable<TResult>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult>([Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult> function, [Nullable(1)] IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, IObservable<TResult>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult>([Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult> function); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, IObservable<TResult>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult>([Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult> function, [Nullable(1)] IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, IObservable<TResult>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult>([Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult> function); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, IObservable<TResult>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult>([Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult> function, [Nullable(1)] IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, IObservable<TResult>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TResult>([Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TResult> function); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, IObservable<TResult>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TResult>([Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TResult> function, [Nullable(1)] IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, IObservable<TResult>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TResult>([Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TResult> function); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, IObservable<TResult>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TResult>([Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TResult> function, [Nullable(1)] IScheduler scheduler); Func<IObservable<Unit>> ToAsync(Action action); Func<IObservable<Unit>> ToAsync(Action action, IScheduler scheduler); Func<TSource, IObservable<Unit>> ToAsync<[Nullable(2)] TSource>(Action<TSource> action); Func<TSource, IObservable<Unit>> ToAsync<[Nullable(2)] TSource>(Action<TSource> action, IScheduler scheduler); Func<T1, T2, IObservable<Unit>> ToAsync<[Nullable(2)] T1, [Nullable(2)] T2>(Action<T1, T2> action); Func<T1, T2, IObservable<Unit>> ToAsync<[Nullable(2)] T1, [Nullable(2)] T2>(Action<T1, T2> action, IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, IObservable<Unit>> ToAsync<T1, T2, T3>([Nullable(1)] Action<T1, T2, T3> action); Func<T1, T2, T3, IObservable<Unit>> ToAsync<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3>(Action<T1, T2, T3> action, IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, IObservable<Unit>> ToAsync<T1, T2, T3, T4>([Nullable(1)] Action<T1, T2, T3, T4> action); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, IObservable<Unit>> ToAsync<T1, T2, T3, T4>([Nullable(1)] Action<T1, T2, T3, T4> action, [Nullable(1)] IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, IObservable<Unit>> ToAsync<T1, T2, T3, T4, T5>([Nullable(1)] Action<T1, T2, T3, T4, T5> action); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, IObservable<Unit>> ToAsync<T1, T2, T3, T4, T5>([Nullable(1)] Action<T1, T2, T3, T4, T5> action, [Nullable(1)] IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, IObservable<Unit>> ToAsync<T1, T2, T3, T4, T5, T6>([Nullable(1)] Action<T1, T2, T3, T4, T5, T6> action); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, IObservable<Unit>> ToAsync<T1, T2, T3, T4, T5, T6>([Nullable(1)] Action<T1, T2, T3, T4, T5, T6> action, [Nullable(1)] IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, IObservable<Unit>> ToAsync<T1, T2, T3, T4, T5, T6, T7>([Nullable(1)] Action<T1, T2, T3, T4, T5, T6, T7> action); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, IObservable<Unit>> ToAsync<T1, T2, T3, T4, T5, T6, T7>([Nullable(1)] Action<T1, T2, T3, T4, T5, T6, T7> action, [Nullable(1)] IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, IObservable<Unit>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8>([Nullable(1)] Action<T1, T2, T3, T4, T5, T6, T7, T8> action); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, IObservable<Unit>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8>([Nullable(1)] Action<T1, T2, T3, T4, T5, T6, T7, T8> action, [Nullable(1)] IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, IObservable<Unit>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9>([Nullable(1)] Action<T1, T2, T3, T4, T5, T6, T7, T8, T9> action); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, IObservable<Unit>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9>([Nullable(1)] Action<T1, T2, T3, T4, T5, T6, T7, T8, T9> action, [Nullable(1)] IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, IObservable<Unit>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10>([Nullable(1)] Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10> action); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, IObservable<Unit>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10>([Nullable(1)] Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10> action, [Nullable(1)] IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, IObservable<Unit>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11>([Nullable(1)] Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11> action); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, IObservable<Unit>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11>([Nullable(1)] Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11> action, [Nullable(1)] IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, IObservable<Unit>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12>([Nullable(1)] Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12> action); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, IObservable<Unit>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12>([Nullable(1)] Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12> action, [Nullable(1)] IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, IObservable<Unit>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13>([Nullable(1)] Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13> action); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, IObservable<Unit>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13>([Nullable(1)] Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13> action, [Nullable(1)] IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, IObservable<Unit>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14>([Nullable(1)] Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14> action); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, IObservable<Unit>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14>([Nullable(1)] Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14> action, [Nullable(1)] IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, IObservable<Unit>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15>([Nullable(1)] Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15> action); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, IObservable<Unit>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15>([Nullable(1)] Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15> action, [Nullable(1)] IScheduler scheduler); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, IObservable<Unit>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16>([Nullable(1)] Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16> action); [NullableContext(2)] [return: Nullable(1)] Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, IObservable<Unit>> ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16>([Nullable(1)] Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16> action, [Nullable(1)] IScheduler scheduler); AsyncSubject<TSource> GetAwaiter<[Nullable(2)] TSource>(IObservable<TSource> source); AsyncSubject<TSource> GetAwaiter<[Nullable(2)] TSource>(IConnectableObservable<TSource> source); AsyncSubject<TSource> RunAsync<[Nullable(2)] TSource>(IObservable<TSource> source, CancellationToken cancellationToken); AsyncSubject<TSource> RunAsync<[Nullable(2)] TSource>(IConnectableObservable<TSource> source, CancellationToken cancellationToken); IConnectableObservable<TResult> Multicast<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, ISubject<TSource, TResult> subject); IObservable<TResult> Multicast<[Nullable(2)] TSource, [Nullable(2)] TIntermediate, [Nullable(2)] TResult>(IObservable<TSource> source, Func<ISubject<TSource, TIntermediate>> subjectSelector, Func<IObservable<TIntermediate>, IObservable<TResult>> selector); IConnectableObservable<TSource> Publish<[Nullable(2)] TSource>(IObservable<TSource> source); IObservable<TResult> Publish<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<IObservable<TSource>, IObservable<TResult>> selector); IConnectableObservable<TSource> Publish<[Nullable(2)] TSource>(IObservable<TSource> source, TSource initialValue); IObservable<TResult> Publish<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<IObservable<TSource>, IObservable<TResult>> selector, TSource initialValue); IConnectableObservable<TSource> PublishLast<[Nullable(2)] TSource>(IObservable<TSource> source); IObservable<TResult> PublishLast<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<IObservable<TSource>, IObservable<TResult>> selector); IObservable<TSource> RefCount<[Nullable(2)] TSource>(IConnectableObservable<TSource> source); IObservable<TSource> RefCount<[Nullable(2)] TSource>(IConnectableObservable<TSource> source, TimeSpan disconnectDelay); IObservable<TSource> RefCount<[Nullable(2)] TSource>(IConnectableObservable<TSource> source, TimeSpan disconnectDelay, IScheduler schedulder); IObservable<TSource> RefCount<[Nullable(2)] TSource>(IConnectableObservable<TSource> source, int minObservers); IObservable<TSource> RefCount<[Nullable(2)] TSource>(IConnectableObservable<TSource> source, int minObservers, TimeSpan disconnectDelay); IObservable<TSource> RefCount<[Nullable(2)] TSource>(IConnectableObservable<TSource> source, int minObservers, TimeSpan disconnectDelay, IScheduler schedulder); IConnectableObservable<TSource> Replay<[Nullable(2)] TSource>(IObservable<TSource> source); IConnectableObservable<TSource> Replay<[Nullable(2)] TSource>(IObservable<TSource> source, IScheduler scheduler); IObservable<TResult> Replay<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<IObservable<TSource>, IObservable<TResult>> selector); IObservable<TResult> Replay<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<IObservable<TSource>, IObservable<TResult>> selector, IScheduler scheduler); IConnectableObservable<TSource> Replay<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan window); IObservable<TResult> Replay<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<IObservable<TSource>, IObservable<TResult>> selector, TimeSpan window); IConnectableObservable<TSource> Replay<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan window, IScheduler scheduler); IObservable<TResult> Replay<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<IObservable<TSource>, IObservable<TResult>> selector, TimeSpan window, IScheduler scheduler); IConnectableObservable<TSource> Replay<[Nullable(2)] TSource>(IObservable<TSource> source, int bufferSize, IScheduler scheduler); IObservable<TResult> Replay<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<IObservable<TSource>, IObservable<TResult>> selector, int bufferSize, IScheduler scheduler); IConnectableObservable<TSource> Replay<[Nullable(2)] TSource>(IObservable<TSource> source, int bufferSize); IObservable<TResult> Replay<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<IObservable<TSource>, IObservable<TResult>> selector, int bufferSize); IConnectableObservable<TSource> Replay<[Nullable(2)] TSource>(IObservable<TSource> source, int bufferSize, TimeSpan window); IObservable<TResult> Replay<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<IObservable<TSource>, IObservable<TResult>> selector, int bufferSize, TimeSpan window); IConnectableObservable<TSource> Replay<[Nullable(2)] TSource>(IObservable<TSource> source, int bufferSize, TimeSpan window, IScheduler scheduler); IObservable<TResult> Replay<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<IObservable<TSource>, IObservable<TResult>> selector, int bufferSize, TimeSpan window, IScheduler scheduler); IObservable<TSource> AutoConnect<[Nullable(2)] TSource>(IConnectableObservable<TSource> source, int minObservers, [Nullable(new byte[] { 2, 1 })] Action<IDisposable> onConnect); IEnumerable<IList<TSource>> Chunkify<[Nullable(2)] TSource>(IObservable<TSource> source); IEnumerable<TResult> Collect<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TResult> newCollector, Func<TResult, TSource, TResult> merge); IEnumerable<TResult> Collect<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TResult> getInitialCollector, Func<TResult, TSource, TResult> merge, Func<TResult, TResult> getNewCollector); TSource First<[Nullable(2)] TSource>(IObservable<TSource> source); TSource First<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, bool> predicate); [return: MaybeNull] TSource FirstOrDefault<[Nullable(2)] TSource>(IObservable<TSource> source); [return: MaybeNull] TSource FirstOrDefault<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, bool> predicate); void ForEach<[Nullable(2)] TSource>(IObservable<TSource> source, Action<TSource> onNext); void ForEach<[Nullable(2)] TSource>(IObservable<TSource> source, Action<TSource, int> onNext); IEnumerator<TSource> GetEnumerator<[Nullable(2)] TSource>(IObservable<TSource> source); TSource Last<[Nullable(2)] TSource>(IObservable<TSource> source); TSource Last<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, bool> predicate); [return: MaybeNull] TSource LastOrDefault<[Nullable(2)] TSource>(IObservable<TSource> source); [return: MaybeNull] TSource LastOrDefault<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, bool> predicate); IEnumerable<TSource> Latest<[Nullable(2)] TSource>(IObservable<TSource> source); IEnumerable<TSource> MostRecent<[Nullable(2)] TSource>(IObservable<TSource> source, TSource initialValue); IEnumerable<TSource> Next<[Nullable(2)] TSource>(IObservable<TSource> source); TSource Single<[Nullable(2)] TSource>(IObservable<TSource> source); [return: MaybeNull] TSource SingleOrDefault<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, bool> predicate); [return: MaybeNull] TSource SingleOrDefault<[Nullable(2)] TSource>(IObservable<TSource> source); TSource Single<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, bool> predicate); TSource Wait<[Nullable(2)] TSource>(IObservable<TSource> source); IObservable<TSource> ObserveOn<[Nullable(2)] TSource>(IObservable<TSource> source, IScheduler scheduler); IObservable<TSource> ObserveOn<[Nullable(2)] TSource>(IObservable<TSource> source, SynchronizationContext context); IObservable<TSource> SubscribeOn<[Nullable(2)] TSource>(IObservable<TSource> source, IScheduler scheduler); IObservable<TSource> SubscribeOn<[Nullable(2)] TSource>(IObservable<TSource> source, SynchronizationContext context); IObservable<TSource> Synchronize<[Nullable(2)] TSource>(IObservable<TSource> source); IObservable<TSource> Synchronize<[Nullable(2)] TSource>(IObservable<TSource> source, object gate); IDisposable Subscribe<[Nullable(2)] TSource>(IEnumerable<TSource> source, IObserver<TSource> observer); IDisposable Subscribe<[Nullable(2)] TSource>(IEnumerable<TSource> source, IObserver<TSource> observer, IScheduler scheduler); IEnumerable<TSource> ToEnumerable<[Nullable(2)] TSource>(IObservable<TSource> source); IEventSource<Unit> ToEvent(IObservable<Unit> source); IEventSource<TSource> ToEvent<[Nullable(2)] TSource>(IObservable<TSource> source); IEventPatternSource<TEventArgs> ToEventPattern<[Nullable(2)] TEventArgs>(IObservable<EventPattern<TEventArgs>> source); IObservable<TSource> ToObservable<[Nullable(2)] TSource>(IEnumerable<TSource> source); IObservable<TSource> ToObservable<[Nullable(2)] TSource>(IEnumerable<TSource> source, IScheduler scheduler); IObservable<TSource> Create<[Nullable(2)] TSource>(Func<IObserver<TSource>, IDisposable> subscribe); IObservable<TSource> Create<[Nullable(2)] TSource>(Func<IObserver<TSource>, Action> subscribe); IObservable<TResult> Create<[Nullable(2)] TResult>(Func<IObserver<TResult>, CancellationToken, Task> subscribeAsync); IObservable<TResult> Create<[Nullable(2)] TResult>(Func<IObserver<TResult>, Task> subscribeAsync); IObservable<TResult> Create<[Nullable(2)] TResult>(Func<IObserver<TResult>, CancellationToken, Task<IDisposable>> subscribeAsync); IObservable<TResult> Create<[Nullable(2)] TResult>(Func<IObserver<TResult>, Task<IDisposable>> subscribeAsync); IObservable<TResult> Create<[Nullable(2)] TResult>(Func<IObserver<TResult>, CancellationToken, Task<Action>> subscribeAsync); IObservable<TResult> Create<[Nullable(2)] TResult>(Func<IObserver<TResult>, Task<Action>> subscribeAsync); IObservable<TValue> Defer<[Nullable(2)] TValue>(Func<IObservable<TValue>> observableFactory); IObservable<TValue> Defer<[Nullable(2)] TValue>(Func<Task<IObservable<TValue>>> observableFactoryAsync, bool ignoreExceptionsAfterUnsubscribe); IObservable<TValue> Defer<[Nullable(2)] TValue>(Func<CancellationToken, Task<IObservable<TValue>>> observableFactoryAsync, bool ignoreExceptionsAfterUnsubscribe); IObservable<TResult> Empty<[Nullable(2)] TResult>(); IObservable<TResult> Empty<[Nullable(2)] TResult>(IScheduler scheduler); IObservable<TResult> Generate<[Nullable(2)] TState, [Nullable(2)] TResult>(TState initialState, Func<TState, bool> condition, Func<TState, TState> iterate, Func<TState, TResult> resultSelector); IObservable<TResult> Generate<[Nullable(2)] TState, [Nullable(2)] TResult>(TState initialState, Func<TState, bool> condition, Func<TState, TState> iterate, Func<TState, TResult> resultSelector, IScheduler scheduler); IObservable<TResult> Never<[Nullable(2)] TResult>(); IObservable<int> Range(int start, int count); IObservable<int> Range(int start, int count, IScheduler scheduler); IObservable<TResult> Repeat<[Nullable(2)] TResult>(TResult value); IObservable<TResult> Repeat<[Nullable(2)] TResult>(TResult value, IScheduler scheduler); IObservable<TResult> Repeat<[Nullable(2)] TResult>(TResult value, int repeatCount); IObservable<TResult> Repeat<[Nullable(2)] TResult>(TResult value, int repeatCount, IScheduler scheduler); IObservable<TResult> Return<[Nullable(2)] TResult>(TResult value); IObservable<TResult> Return<[Nullable(2)] TResult>(TResult value, IScheduler scheduler); IObservable<TResult> Throw<[Nullable(2)] TResult>(Exception exception); IObservable<TResult> Throw<[Nullable(2)] TResult>(Exception exception, IScheduler scheduler); IObservable<TSource> Using<[Nullable(2)] TSource, [Nullable(0)] TResource>(Func<TResource> resourceFactory, Func<TResource, IObservable<TSource>> observableFactory) where TResource : IDisposable; IObservable<TSource> Using<[Nullable(2)] TSource, [Nullable(0)] TResource>(Func<CancellationToken, Task<TResource>> resourceFactoryAsync, Func<TResource, CancellationToken, Task<IObservable<TSource>>> observableFactoryAsync) where TResource : IDisposable; IObservable<EventPattern<object>> FromEventPattern(Action<EventHandler> addHandler, Action<EventHandler> removeHandler); IObservable<EventPattern<object>> FromEventPattern(Action<EventHandler> addHandler, Action<EventHandler> removeHandler, IScheduler scheduler); IObservable<EventPattern<TEventArgs>> FromEventPattern<[Nullable(2)] TDelegate, [Nullable(2)] TEventArgs>(Action<TDelegate> addHandler, Action<TDelegate> removeHandler); IObservable<EventPattern<TEventArgs>> FromEventPattern<[Nullable(2)] TDelegate, [Nullable(2)] TEventArgs>(Action<TDelegate> addHandler, Action<TDelegate> removeHandler, IScheduler scheduler); IObservable<EventPattern<TEventArgs>> FromEventPattern<[Nullable(2)] TDelegate, [Nullable(2)] TEventArgs>(Func<EventHandler<TEventArgs>, TDelegate> conversion, Action<TDelegate> addHandler, Action<TDelegate> removeHandler); IObservable<EventPattern<TEventArgs>> FromEventPattern<[Nullable(2)] TDelegate, [Nullable(2)] TEventArgs>(Func<EventHandler<TEventArgs>, TDelegate> conversion, Action<TDelegate> addHandler, Action<TDelegate> removeHandler, IScheduler scheduler); IObservable<EventPattern<TEventArgs>> FromEventPattern<[Nullable(2)] TEventArgs>(Action<EventHandler<TEventArgs>> addHandler, Action<EventHandler<TEventArgs>> removeHandler); IObservable<EventPattern<TEventArgs>> FromEventPattern<[Nullable(2)] TEventArgs>(Action<EventHandler<TEventArgs>> addHandler, Action<EventHandler<TEventArgs>> removeHandler, IScheduler scheduler); IObservable<EventPattern<TSender, TEventArgs>> FromEventPattern<[Nullable(2)] TDelegate, [Nullable(2)] TSender, [Nullable(2)] TEventArgs>(Action<TDelegate> addHandler, Action<TDelegate> removeHandler); IObservable<EventPattern<TSender, TEventArgs>> FromEventPattern<[Nullable(2)] TDelegate, [Nullable(2)] TSender, [Nullable(2)] TEventArgs>(Action<TDelegate> addHandler, Action<TDelegate> removeHandler, IScheduler scheduler); [RequiresUnreferencedCode("This member uses reflection to discover event members and associated delegate types.")] IObservable<EventPattern<object>> FromEventPattern(object target, string eventName); [RequiresUnreferencedCode("This member uses reflection to discover event members and associated delegate types.")] IObservable<EventPattern<object>> FromEventPattern(object target, string eventName, IScheduler scheduler); [RequiresUnreferencedCode("This member uses reflection to discover event members and associated delegate types.")] IObservable<EventPattern<TEventArgs>> FromEventPattern<[Nullable(2)] TEventArgs>(object target, string eventName); [RequiresUnreferencedCode("This member uses reflection to discover event members and associated delegate types.")] IObservable<EventPattern<TEventArgs>> FromEventPattern<[Nullable(2)] TEventArgs>(object target, string eventName, IScheduler scheduler); [RequiresUnreferencedCode("This member uses reflection to discover event members and associated delegate types.")] IObservable<EventPattern<TSender, TEventArgs>> FromEventPattern<[Nullable(2)] TSender, [Nullable(2)] TEventArgs>(object target, string eventName); [RequiresUnreferencedCode("This member uses reflection to discover event members and associated delegate types.")] IObservable<EventPattern<TSender, TEventArgs>> FromEventPattern<[Nullable(2)] TSender, [Nullable(2)] TEventArgs>(object target, string eventName, IScheduler scheduler); [RequiresUnreferencedCode("This member uses reflection to discover event members and associated delegate types.")] IObservable<EventPattern<object>> FromEventPattern(Type type, string eventName); [RequiresUnreferencedCode("This member uses reflection to discover event members and associated delegate types.")] IObservable<EventPattern<object>> FromEventPattern(Type type, string eventName, IScheduler scheduler); [RequiresUnreferencedCode("This member uses reflection to discover event members and associated delegate types.")] IObservable<EventPattern<TEventArgs>> FromEventPattern<[Nullable(2)] TEventArgs>(Type type, string eventName); [RequiresUnreferencedCode("This member uses reflection to discover event members and associated delegate types.")] IObservable<EventPattern<TEventArgs>> FromEventPattern<[Nullable(2)] TEventArgs>(Type type, string eventName, IScheduler scheduler); [RequiresUnreferencedCode("This member uses reflection to discover event members and associated delegate types.")] IObservable<EventPattern<TSender, TEventArgs>> FromEventPattern<[Nullable(2)] TSender, [Nullable(2)] TEventArgs>(Type type, string eventName); [RequiresUnreferencedCode("This member uses reflection to discover event members and associated delegate types.")] IObservable<EventPattern<TSender, TEventArgs>> FromEventPattern<[Nullable(2)] TSender, [Nullable(2)] TEventArgs>(Type type, string eventName, IScheduler scheduler); IObservable<TEventArgs> FromEvent<[Nullable(2)] TDelegate, [Nullable(2)] TEventArgs>(Func<Action<TEventArgs>, TDelegate> conversion, Action<TDelegate> addHandler, Action<TDelegate> removeHandler); IObservable<TEventArgs> FromEvent<[Nullable(2)] TDelegate, [Nullable(2)] TEventArgs>(Func<Action<TEventArgs>, TDelegate> conversion, Action<TDelegate> addHandler, Action<TDelegate> removeHandler, IScheduler scheduler); IObservable<TEventArgs> FromEvent<[Nullable(2)] TDelegate, [Nullable(2)] TEventArgs>(Action<TDelegate> addHandler, Action<TDelegate> removeHandler); IObservable<TEventArgs> FromEvent<[Nullable(2)] TDelegate, [Nullable(2)] TEventArgs>(Action<TDelegate> addHandler, Action<TDelegate> removeHandler, IScheduler scheduler); IObservable<TEventArgs> FromEvent<[Nullable(2)] TEventArgs>(Action<Action<TEventArgs>> addHandler, Action<Action<TEventArgs>> removeHandler); IObservable<TEventArgs> FromEvent<[Nullable(2)] TEventArgs>(Action<Action<TEventArgs>> addHandler, Action<Action<TEventArgs>> removeHandler, IScheduler scheduler); IObservable<Unit> FromEvent(Action<Action> addHandler, Action<Action> removeHandler); IObservable<Unit> FromEvent(Action<Action> addHandler, Action<Action> removeHandler, IScheduler scheduler); Task ForEachAsync<[Nullable(2)] TSource>(IObservable<TSource> source, Action<TSource> onNext); Task ForEachAsync<[Nullable(2)] TSource>(IObservable<TSource> source, Action<TSource> onNext, CancellationToken cancellationToken); Task ForEachAsync<[Nullable(2)] TSource>(IObservable<TSource> source, Action<TSource, int> onNext); Task ForEachAsync<[Nullable(2)] TSource>(IObservable<TSource> source, Action<TSource, int> onNext, CancellationToken cancellationToken); IObservable<TResult> Case<TValue, [Nullable(2)] TResult>(Func<TValue> selector, IDictionary<TValue, IObservable<TResult>> sources, IObservable<TResult> defaultSource); IObservable<TResult> Case<TValue, [Nullable(2)] TResult>(Func<TValue> selector, IDictionary<TValue, IObservable<TResult>> sources, IScheduler scheduler); IObservable<TResult> Case<TValue, [Nullable(2)] TResult>(Func<TValue> selector, IDictionary<TValue, IObservable<TResult>> sources); IObservable<TSource> DoWhile<[Nullable(2)] TSource>(IObservable<TSource> source, Func<bool> condition); IObservable<TResult> For<[Nullable(2)] TSource, [Nullable(2)] TResult>(IEnumerable<TSource> source, Func<TSource, IObservable<TResult>> resultSelector); IObservable<TResult> If<[Nullable(2)] TResult>(Func<bool> condition, IObservable<TResult> thenSource, IObservable<TResult> elseSource); IObservable<TResult> If<[Nullable(2)] TResult>(Func<bool> condition, IObservable<TResult> thenSource); IObservable<TResult> If<[Nullable(2)] TResult>(Func<bool> condition, IObservable<TResult> thenSource, IScheduler scheduler); IObservable<TSource> While<[Nullable(2)] TSource>(Func<bool> condition, IObservable<TSource> source); Pattern<TLeft, TRight> And<[Nullable(2)] TLeft, [Nullable(2)] TRight>(IObservable<TLeft> left, IObservable<TRight> right); Plan<TResult> Then<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TSource, TResult> selector); IObservable<TResult> When<[Nullable(2)] TResult>(params Plan<TResult>[] plans); IObservable<TResult> When<[Nullable(2)] TResult>(IEnumerable<Plan<TResult>> plans); IObservable<TSource> Amb<[Nullable(2)] TSource>(IObservable<TSource> first, IObservable<TSource> second); IObservable<TSource> Amb<[Nullable(2)] TSource>(params IObservable<TSource>[] sources); IObservable<TSource> Amb<[Nullable(2)] TSource>(IEnumerable<IObservable<TSource>> sources); IObservable<IList<TSource>> Buffer<[Nullable(2)] TSource, [Nullable(2)] TBufferClosing>(IObservable<TSource> source, Func<IObservable<TBufferClosing>> bufferClosingSelector); IObservable<IList<TSource>> Buffer<[Nullable(2)] TSource, [Nullable(2)] TBufferOpening, [Nullable(2)] TBufferClosing>(IObservable<TSource> source, IObservable<TBufferOpening> bufferOpenings, Func<TBufferOpening, IObservable<TBufferClosing>> bufferClosingSelector); IObservable<IList<TSource>> Buffer<[Nullable(2)] TSource, [Nullable(2)] TBufferBoundary>(IObservable<TSource> source, IObservable<TBufferBoundary> bufferBoundaries); IObservable<TSource> Catch<[Nullable(2)] TSource, [Nullable(0)] TException>(IObservable<TSource> source, Func<TException, IObservable<TSource>> handler) where TException : Exception; IObservable<TSource> Catch<[Nullable(2)] TSource>(IObservable<TSource> first, IObservable<TSource> second); IObservable<TSource> Catch<[Nullable(2)] TSource>(params IObservable<TSource>[] sources); IObservable<TSource> Catch<[Nullable(2)] TSource>(IEnumerable<IObservable<TSource>> sources); IObservable<TResult> CombineLatest<[Nullable(2)] TSource, [Nullable(2)] TResult>(IEnumerable<IObservable<TSource>> sources, Func<IList<TSource>, TResult> resultSelector); IObservable<IList<TSource>> CombineLatest<[Nullable(2)] TSource>(IEnumerable<IObservable<TSource>> sources); IObservable<IList<TSource>> CombineLatest<[Nullable(2)] TSource>(params IObservable<TSource>[] sources); IObservable<TSource> Concat<[Nullable(2)] TSource>(IObservable<TSource> first, IObservable<TSource> second); IObservable<TSource> Concat<[Nullable(2)] TSource>(params IObservable<TSource>[] sources); IObservable<TSource> Concat<[Nullable(2)] TSource>(IEnumerable<IObservable<TSource>> sources); IObservable<TSource> Concat<[Nullable(2)] TSource>(IObservable<IObservable<TSource>> sources); IObservable<TSource> Merge<[Nullable(2)] TSource>(IObservable<IObservable<TSource>> sources); IObservable<TSource> Merge<[Nullable(2)] TSource>(IObservable<IObservable<TSource>> sources, int maxConcurrent); IObservable<TSource> Merge<[Nullable(2)] TSource>(IEnumerable<IObservable<TSource>> sources, int maxConcurrent); IObservable<TSource> Merge<[Nullable(2)] TSource>(IEnumerable<IObservable<TSource>> sources, int maxConcurrent, IScheduler scheduler); IObservable<TSource> Merge<[Nullable(2)] TSource>(IObservable<TSource> first, IObservable<TSource> second); IObservable<TSource> Merge<[Nullable(2)] TSource>(IObservable<TSource> first, IObservable<TSource> second, IScheduler scheduler); IObservable<TSource> Merge<[Nullable(2)] TSource>(params IObservable<TSource>[] sources); IObservable<TSource> Merge<[Nullable(2)] TSource>(IScheduler scheduler, params IObservable<TSource>[] sources); IObservable<TSource> Merge<[Nullable(2)] TSource>(IEnumerable<IObservable<TSource>> sources); IObservable<TSource> Merge<[Nullable(2)] TSource>(IEnumerable<IObservable<TSource>> sources, IScheduler scheduler); IObservable<TSource> OnErrorResumeNext<[Nullable(2)] TSource>(IObservable<TSource> first, IObservable<TSource> second); IObservable<TSource> OnErrorResumeNext<[Nullable(2)] TSource>(params IObservable<TSource>[] sources); IObservable<TSource> OnErrorResumeNext<[Nullable(2)] TSource>(IEnumerable<IObservable<TSource>> sources); IObservable<TSource> SkipUntil<[Nullable(2)] TSource, [Nullable(2)] TOther>(IObservable<TSource> source, IObservable<TOther> other); IObservable<TSource> Switch<[Nullable(2)] TSource>(IObservable<IObservable<TSource>> sources); IObservable<TSource> TakeUntil<[Nullable(2)] TSource, [Nullable(2)] TOther>(IObservable<TSource> source, IObservable<TOther> other); IObservable<TSource> TakeUntil<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, bool> stopPredicate); IObservable<TSource> TakeUntil<[Nullable(2)] TSource>(IObservable<TSource> source, CancellationToken cancellationToken); IObservable<IObservable<TSource>> Window<[Nullable(2)] TSource, [Nullable(2)] TWindowClosing>(IObservable<TSource> source, Func<IObservable<TWindowClosing>> windowClosingSelector); IObservable<IObservable<TSource>> Window<[Nullable(2)] TSource, [Nullable(2)] TWindowOpening, [Nullable(2)] TWindowClosing>(IObservable<TSource> source, IObservable<TWindowOpening> windowOpenings, Func<TWindowOpening, IObservable<TWindowClosing>> windowClosingSelector); IObservable<IObservable<TSource>> Window<[Nullable(2)] TSource, [Nullable(2)] TWindowBoundary>(IObservable<TSource> source, IObservable<TWindowBoundary> windowBoundaries); IObservable<TResult> WithLatestFrom<[Nullable(2)] TFirst, [Nullable(2)] TSecond, [Nullable(2)] TResult>(IObservable<TFirst> first, IObservable<TSecond> second, Func<TFirst, TSecond, TResult> resultSelector); IObservable<TResult> Zip<[Nullable(2)] TSource, [Nullable(2)] TResult>(IEnumerable<IObservable<TSource>> sources, Func<IList<TSource>, TResult> resultSelector); IObservable<IList<TSource>> Zip<[Nullable(2)] TSource>(IEnumerable<IObservable<TSource>> sources); IObservable<IList<TSource>> Zip<[Nullable(2)] TSource>(params IObservable<TSource>[] sources); IObservable<TResult> Zip<[Nullable(2)] TFirst, [Nullable(2)] TSecond, [Nullable(2)] TResult>(IObservable<TFirst> first, IEnumerable<TSecond> second, Func<TFirst, TSecond, TResult> resultSelector); IObservable<TSource> Concat<[Nullable(2)] TSource>(IObservable<Task<TSource>> sources); IObservable<TSource> Merge<[Nullable(2)] TSource>(IObservable<Task<TSource>> sources); IObservable<TSource> Switch<[Nullable(2)] TSource>(IObservable<Task<TSource>> sources); IObservable<TSource> Append<[Nullable(2)] TSource>(IObservable<TSource> source, TSource value); IObservable<TSource> Append<[Nullable(2)] TSource>(IObservable<TSource> source, TSource value, IScheduler scheduler); IObservable<TSource> AsObservable<[Nullable(2)] TSource>(IObservable<TSource> source); IObservable<IList<TSource>> Buffer<[Nullable(2)] TSource>(IObservable<TSource> source, int count); IObservable<IList<TSource>> Buffer<[Nullable(2)] TSource>(IObservable<TSource> source, int count, int skip); IObservable<TSource> ResetExceptionDispatchState<[Nullable(2)] TSource>(IObservable<TSource> source); IObservable<TSource> Dematerialize<[Nullable(2)] TSource>(IObservable<Notification<TSource>> source); IObservable<TSource> DistinctUntilChanged<[Nullable(2)] TSource>(IObservable<TSource> source); IObservable<TSource> DistinctUntilChanged<[Nullable(2)] TSource>(IObservable<TSource> source, IEqualityComparer<TSource> comparer); IObservable<TSource> DistinctUntilChanged<[Nullable(2)] TSource, [Nullable(2)] TKey>(IObservable<TSource> source, Func<TSource, TKey> keySelector); IObservable<TSource> DistinctUntilChanged<[Nullable(2)] TSource, [Nullable(2)] TKey>(IObservable<TSource> source, Func<TSource, TKey> keySelector, IEqualityComparer<TKey> comparer); IObservable<TSource> Do<[Nullable(2)] TSource>(IObservable<TSource> source, Action<TSource> onNext); IObservable<TSource> Do<[Nullable(2)] TSource>(IObservable<TSource> source, Action<TSource> onNext, Action onCompleted); IObservable<TSource> Do<[Nullable(2)] TSource>(IObservable<TSource> source, Action<TSource> onNext, Action<Exception> onError); IObservable<TSource> Do<[Nullable(2)] TSource>(IObservable<TSource> source, Action<TSource> onNext, Action<Exception> onError, Action onCompleted); IObservable<TSource> Do<[Nullable(2)] TSource>(IObservable<TSource> source, IObserver<TSource> observer); IObservable<TSource> Finally<[Nullable(2)] TSource>(IObservable<TSource> source, Action finallyAction); IObservable<TSource> IgnoreElements<[Nullable(2)] TSource>(IObservable<TSource> source); IObservable<Notification<TSource>> Materialize<[Nullable(2)] TSource>(IObservable<TSource> source); IObservable<TSource> Prepend<[Nullable(2)] TSource>(IObservable<TSource> source, TSource value); IObservable<TSource> Prepend<[Nullable(2)] TSource>(IObservable<TSource> source, TSource value, IScheduler scheduler); IObservable<TSource> Repeat<[Nullable(2)] TSource>(IObservable<TSource> source); IObservable<TSource> Repeat<[Nullable(2)] TSource>(IObservable<TSource> source, int repeatCount); IObservable<TSource> RepeatWhen<[Nullable(2)] TSource, [Nullable(2)] TSignal>(IObservable<TSource> source, Func<IObservable<object>, IObservable<TSignal>> handler); IObservable<TSource> Retry<[Nullable(2)] TSource>(IObservable<TSource> source); IObservable<TSource> Retry<[Nullable(2)] TSource>(IObservable<TSource> source, int retryCount); IObservable<TSource> RetryWhen<[Nullable(2)] TSource, [Nullable(2)] TSignal>(IObservable<TSource> source, Func<IObservable<Exception>, IObservable<TSignal>> handler); IObservable<TAccumulate> Scan<[Nullable(2)] TSource, [Nullable(2)] TAccumulate>(IObservable<TSource> source, TAccumulate seed, Func<TAccumulate, TSource, TAccumulate> accumulator); IObservable<TSource> Scan<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, TSource, TSource> accumulator); IObservable<TSource> SkipLast<[Nullable(2)] TSource>(IObservable<TSource> source, int count); IObservable<TSource> StartWith<[Nullable(2)] TSource>(IObservable<TSource> source, params TSource[] values); IObservable<TSource> StartWith<[Nullable(2)] TSource>(IObservable<TSource> source, IScheduler scheduler, params TSource[] values); IObservable<TSource> StartWith<[Nullable(2)] TSource>(IObservable<TSource> source, IEnumerable<TSource> values); IObservable<TSource> StartWith<[Nullable(2)] TSource>(IObservable<TSource> source, IScheduler scheduler, IEnumerable<TSource> values); IObservable<TSource> TakeLast<[Nullable(2)] TSource>(IObservable<TSource> source, int count); IObservable<TSource> TakeLast<[Nullable(2)] TSource>(IObservable<TSource> source, int count, IScheduler scheduler); IObservable<IList<TSource>> TakeLastBuffer<[Nullable(2)] TSource>(IObservable<TSource> source, int count); IObservable<IObservable<TSource>> Window<[Nullable(2)] TSource>(IObservable<TSource> source, int count, int skip); IObservable<IObservable<TSource>> Window<[Nullable(2)] TSource>(IObservable<TSource> source, int count); IObservable<TResult> Cast<[Nullable(2)] TResult>(IObservable<object> source); [return: Nullable(new byte[] { 1, 2 })] IObservable<TSource> DefaultIfEmpty<[Nullable(2)] TSource>(IObservable<TSource> source); IObservable<TSource> DefaultIfEmpty<[Nullable(2)] TSource>(IObservable<TSource> source, TSource defaultValue); IObservable<TSource> Distinct<[Nullable(2)] TSource>(IObservable<TSource> source); IObservable<TSource> Distinct<[Nullable(2)] TSource>(IObservable<TSource> source, IEqualityComparer<TSource> comparer); IObservable<TSource> Distinct<[Nullable(2)] TSource, [Nullable(2)] TKey>(IObservable<TSource> source, Func<TSource, TKey> keySelector); IObservable<TSource> Distinct<[Nullable(2)] TSource, [Nullable(2)] TKey>(IObservable<TSource> source, Func<TSource, TKey> keySelector, IEqualityComparer<TKey> comparer); IObservable<IGroupedObservable<TKey, TElement>> GroupBy<[Nullable(2)] TSource, [Nullable(2)] TKey, [Nullable(2)] TElement>(IObservable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector); IObservable<IGroupedObservable<TKey, TSource>> GroupBy<[Nullable(2)] TSource, [Nullable(2)] TKey>(IObservable<TSource> source, Func<TSource, TKey> keySelector, IEqualityComparer<TKey> comparer); IObservable<IGroupedObservable<TKey, TSource>> GroupBy<[Nullable(2)] TSource, [Nullable(2)] TKey>(IObservable<TSource> source, Func<TSource, TKey> keySelector); IObservable<IGroupedObservable<TKey, TElement>> GroupBy<[Nullable(2)] TSource, [Nullable(2)] TKey, [Nullable(2)] TElement>(IObservable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, IEqualityComparer<TKey> comparer); IObservable<IGroupedObservable<TKey, TElement>> GroupBy<[Nullable(2)] TSource, [Nullable(2)] TKey, [Nullable(2)] TElement>(IObservable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, int capacity); IObservable<IGroupedObservable<TKey, TSource>> GroupBy<[Nullable(2)] TSource, [Nullable(2)] TKey>(IObservable<TSource> source, Func<TSource, TKey> keySelector, int capacity, IEqualityComparer<TKey> comparer); IObservable<IGroupedObservable<TKey, TSource>> GroupBy<[Nullable(2)] TSource, [Nullable(2)] TKey>(IObservable<TSource> source, Func<TSource, TKey> keySelector, int capacity); IObservable<IGroupedObservable<TKey, TElement>> GroupBy<[Nullable(2)] TSource, [Nullable(2)] TKey, [Nullable(2)] TElement>(IObservable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, int capacity, IEqualityComparer<TKey> comparer); IObservable<IGroupedObservable<TKey, TElement>> GroupByUntil<[Nullable(2)] TSource, [Nullable(2)] TKey, [Nullable(2)] TElement, [Nullable(2)] TDuration>(IObservable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, Func<IGroupedObservable<TKey, TElement>, IObservable<TDuration>> durationSelector, IEqualityComparer<TKey> comparer); IObservable<IGroupedObservable<TKey, TElement>> GroupByUntil<[Nullable(2)] TSource, [Nullable(2)] TKey, [Nullable(2)] TElement, [Nullable(2)] TDuration>(IObservable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, Func<IGroupedObservable<TKey, TElement>, IObservable<TDuration>> durationSelector); IObservable<IGroupedObservable<TKey, TSource>> GroupByUntil<[Nullable(2)] TSource, [Nullable(2)] TKey, [Nullable(2)] TDuration>(IObservable<TSource> source, Func<TSource, TKey> keySelector, Func<IGroupedObservable<TKey, TSource>, IObservable<TDuration>> durationSelector, IEqualityComparer<TKey> comparer); IObservable<IGroupedObservable<TKey, TSource>> GroupByUntil<[Nullable(2)] TSource, [Nullable(2)] TKey, [Nullable(2)] TDuration>(IObservable<TSource> source, Func<TSource, TKey> keySelector, Func<IGroupedObservable<TKey, TSource>, IObservable<TDuration>> durationSelector); IObservable<IGroupedObservable<TKey, TElement>> GroupByUntil<[Nullable(2)] TSource, [Nullable(2)] TKey, [Nullable(2)] TElement, [Nullable(2)] TDuration>(IObservable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, Func<IGroupedObservable<TKey, TElement>, IObservable<TDuration>> durationSelector, int capacity, IEqualityComparer<TKey> comparer); IObservable<IGroupedObservable<TKey, TElement>> GroupByUntil<[Nullable(2)] TSource, [Nullable(2)] TKey, [Nullable(2)] TElement, [Nullable(2)] TDuration>(IObservable<TSource> source, Func<TSource, TKey> keySelector, Func<TSource, TElement> elementSelector, Func<IGroupedObservable<TKey, TElement>, IObservable<TDuration>> durationSelector, int capacity); IObservable<IGroupedObservable<TKey, TSource>> GroupByUntil<[Nullable(2)] TSource, [Nullable(2)] TKey, [Nullable(2)] TDuration>(IObservable<TSource> source, Func<TSource, TKey> keySelector, Func<IGroupedObservable<TKey, TSource>, IObservable<TDuration>> durationSelector, int capacity, IEqualityComparer<TKey> comparer); IObservable<IGroupedObservable<TKey, TSource>> GroupByUntil<[Nullable(2)] TSource, [Nullable(2)] TKey, [Nullable(2)] TDuration>(IObservable<TSource> source, Func<TSource, TKey> keySelector, Func<IGroupedObservable<TKey, TSource>, IObservable<TDuration>> durationSelector, int capacity); IObservable<TResult> GroupJoin<[Nullable(2)] TLeft, [Nullable(2)] TRight, [Nullable(2)] TLeftDuration, [Nullable(2)] TRightDuration, [Nullable(2)] TResult>(IObservable<TLeft> left, IObservable<TRight> right, Func<TLeft, IObservable<TLeftDuration>> leftDurationSelector, Func<TRight, IObservable<TRightDuration>> rightDurationSelector, Func<TLeft, IObservable<TRight>, TResult> resultSelector); IObservable<TResult> Join<[Nullable(2)] TLeft, [Nullable(2)] TRight, [Nullable(2)] TLeftDuration, [Nullable(2)] TRightDuration, [Nullable(2)] TResult>(IObservable<TLeft> left, IObservable<TRight> right, Func<TLeft, IObservable<TLeftDuration>> leftDurationSelector, Func<TRight, IObservable<TRightDuration>> rightDurationSelector, Func<TLeft, TRight, TResult> resultSelector); IObservable<TResult> OfType<[Nullable(2)] TResult>([Nullable(new byte[] { 1, 2 })] IObservable<object> source); IObservable<TResult> Select<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TSource, TResult> selector); IObservable<TResult> Select<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TSource, int, TResult> selector); IObservable<TOther> SelectMany<[Nullable(2)] TSource, [Nullable(2)] TOther>(IObservable<TSource> source, IObservable<TOther> other); IObservable<TResult> SelectMany<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TSource, IObservable<TResult>> selector); IObservable<TResult> SelectMany<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TSource, int, IObservable<TResult>> selector); IObservable<TResult> SelectMany<[Nullable(2)] TSource, [Nullable(2)] TCollection, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TSource, IObservable<TCollection>> collectionSelector, Func<TSource, TCollection, TResult> resultSelector); IObservable<TResult> SelectMany<[Nullable(2)] TSource, [Nullable(2)] TCollection, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TSource, int, IObservable<TCollection>> collectionSelector, Func<TSource, int, TCollection, int, TResult> resultSelector); IObservable<TResult> SelectMany<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TSource, IObservable<TResult>> onNext, Func<Exception, IObservable<TResult>> onError, Func<IObservable<TResult>> onCompleted); IObservable<TResult> SelectMany<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TSource, int, IObservable<TResult>> onNext, Func<Exception, IObservable<TResult>> onError, Func<IObservable<TResult>> onCompleted); IObservable<TResult> SelectMany<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TSource, IEnumerable<TResult>> selector); IObservable<TResult> SelectMany<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TSource, int, IEnumerable<TResult>> selector); IObservable<TResult> SelectMany<[Nullable(2)] TSource, [Nullable(2)] TCollection, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TSource, IEnumerable<TCollection>> collectionSelector, Func<TSource, TCollection, TResult> resultSelector); IObservable<TResult> SelectMany<[Nullable(2)] TSource, [Nullable(2)] TCollection, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TSource, int, IEnumerable<TCollection>> collectionSelector, Func<TSource, int, TCollection, int, TResult> resultSelector); IObservable<TSource> Skip<[Nullable(2)] TSource>(IObservable<TSource> source, int count); IObservable<TSource> SkipWhile<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, bool> predicate); IObservable<TSource> SkipWhile<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, int, bool> predicate); IObservable<TSource> Take<[Nullable(2)] TSource>(IObservable<TSource> source, int count); IObservable<TSource> Take<[Nullable(2)] TSource>(IObservable<TSource> source, int count, IScheduler scheduler); IObservable<TSource> TakeWhile<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, bool> predicate); IObservable<TSource> TakeWhile<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, int, bool> predicate); IObservable<TSource> Where<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, bool> predicate); IObservable<TSource> Where<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, int, bool> predicate); IObservable<TResult> SelectMany<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TSource, Task<TResult>> selector); IObservable<TResult> SelectMany<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TSource, int, Task<TResult>> selector); IObservable<TResult> SelectMany<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TSource, CancellationToken, Task<TResult>> selector); IObservable<TResult> SelectMany<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TSource, int, CancellationToken, Task<TResult>> selector); IObservable<TResult> SelectMany<[Nullable(2)] TSource, [Nullable(2)] TTaskResult, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TSource, Task<TTaskResult>> taskSelector, Func<TSource, TTaskResult, TResult> resultSelector); IObservable<TResult> SelectMany<[Nullable(2)] TSource, [Nullable(2)] TTaskResult, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TSource, int, Task<TTaskResult>> taskSelector, Func<TSource, int, TTaskResult, TResult> resultSelector); IObservable<TResult> SelectMany<[Nullable(2)] TSource, [Nullable(2)] TTaskResult, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TSource, CancellationToken, Task<TTaskResult>> taskSelector, Func<TSource, TTaskResult, TResult> resultSelector); IObservable<TResult> SelectMany<[Nullable(2)] TSource, [Nullable(2)] TTaskResult, [Nullable(2)] TResult>(IObservable<TSource> source, Func<TSource, int, CancellationToken, Task<TTaskResult>> taskSelector, Func<TSource, int, TTaskResult, TResult> resultSelector); IObservable<IList<TSource>> Buffer<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan timeSpan); IObservable<IList<TSource>> Buffer<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan timeSpan, IScheduler scheduler); IObservable<IList<TSource>> Buffer<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan timeSpan, TimeSpan timeShift); IObservable<IList<TSource>> Buffer<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan timeSpan, TimeSpan timeShift, IScheduler scheduler); IObservable<IList<TSource>> Buffer<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan timeSpan, int count); IObservable<IList<TSource>> Buffer<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan timeSpan, int count, IScheduler scheduler); IObservable<TSource> Delay<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan dueTime); IObservable<TSource> Delay<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan dueTime, IScheduler scheduler); IObservable<TSource> Delay<[Nullable(2)] TSource>(IObservable<TSource> source, DateTimeOffset dueTime); IObservable<TSource> Delay<[Nullable(2)] TSource>(IObservable<TSource> source, DateTimeOffset dueTime, IScheduler scheduler); IObservable<TSource> Delay<[Nullable(2)] TSource, [Nullable(2)] TDelay>(IObservable<TSource> source, Func<TSource, IObservable<TDelay>> delayDurationSelector); IObservable<TSource> Delay<[Nullable(2)] TSource, [Nullable(2)] TDelay>(IObservable<TSource> source, IObservable<TDelay> subscriptionDelay, Func<TSource, IObservable<TDelay>> delayDurationSelector); IObservable<TSource> DelaySubscription<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan dueTime); IObservable<TSource> DelaySubscription<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan dueTime, IScheduler scheduler); IObservable<TSource> DelaySubscription<[Nullable(2)] TSource>(IObservable<TSource> source, DateTimeOffset dueTime); IObservable<TSource> DelaySubscription<[Nullable(2)] TSource>(IObservable<TSource> source, DateTimeOffset dueTime, IScheduler scheduler); IObservable<TResult> Generate<[Nullable(2)] TState, [Nullable(2)] TResult>(TState initialState, Func<TState, bool> condition, Func<TState, TState> iterate, Func<TState, TResult> resultSelector, Func<TState, TimeSpan> timeSelector); IObservable<TResult> Generate<[Nullable(2)] TState, [Nullable(2)] TResult>(TState initialState, Func<TState, bool> condition, Func<TState, TState> iterate, Func<TState, TResult> resultSelector, Func<TState, TimeSpan> timeSelector, IScheduler scheduler); IObservable<TResult> Generate<[Nullable(2)] TState, [Nullable(2)] TResult>(TState initialState, Func<TState, bool> condition, Func<TState, TState> iterate, Func<TState, TResult> resultSelector, Func<TState, DateTimeOffset> timeSelector); IObservable<TResult> Generate<[Nullable(2)] TState, [Nullable(2)] TResult>(TState initialState, Func<TState, bool> condition, Func<TState, TState> iterate, Func<TState, TResult> resultSelector, Func<TState, DateTimeOffset> timeSelector, IScheduler scheduler); IObservable<long> Interval(TimeSpan period); IObservable<long> Interval(TimeSpan period, IScheduler scheduler); IObservable<TSource> Sample<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan interval); IObservable<TSource> Sample<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan interval, IScheduler scheduler); IObservable<TSource> Sample<[Nullable(2)] TSource, [Nullable(2)] TSample>(IObservable<TSource> source, IObservable<TSample> sampler); IObservable<TSource> Skip<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan duration); IObservable<TSource> Skip<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan duration, IScheduler scheduler); IObservable<TSource> SkipLast<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan duration); IObservable<TSource> SkipLast<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan duration, IScheduler scheduler); IObservable<TSource> SkipUntil<[Nullable(2)] TSource>(IObservable<TSource> source, DateTimeOffset startTime); IObservable<TSource> SkipUntil<[Nullable(2)] TSource>(IObservable<TSource> source, DateTimeOffset startTime, IScheduler scheduler); IObservable<TSource> Take<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan duration); IObservable<TSource> Take<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan duration, IScheduler scheduler); IObservable<TSource> TakeLast<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan duration); IObservable<TSource> TakeLast<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan duration, IScheduler scheduler); IObservable<TSource> TakeLast<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan duration, IScheduler timerScheduler, IScheduler loopScheduler); IObservable<IList<TSource>> TakeLastBuffer<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan duration); IObservable<IList<TSource>> TakeLastBuffer<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan duration, IScheduler scheduler); IObservable<TSource> TakeUntil<[Nullable(2)] TSource>(IObservable<TSource> source, DateTimeOffset endTime); IObservable<TSource> TakeUntil<[Nullable(2)] TSource>(IObservable<TSource> source, DateTimeOffset endTime, IScheduler scheduler); IObservable<TSource> Throttle<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan dueTime); IObservable<TSource> Throttle<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan dueTime, IScheduler scheduler); IObservable<TSource> Throttle<[Nullable(2)] TSource, [Nullable(2)] TThrottle>(IObservable<TSource> source, Func<TSource, IObservable<TThrottle>> throttleDurationSelector); [return: Nullable(new byte[] { 1, 0, 1 })] IObservable<TimeInterval<TSource>> TimeInterval<[Nullable(2)] TSource>(IObservable<TSource> source); [return: Nullable(new byte[] { 1, 0, 1 })] IObservable<TimeInterval<TSource>> TimeInterval<[Nullable(2)] TSource>(IObservable<TSource> source, IScheduler scheduler); IObservable<TSource> Timeout<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan dueTime); IObservable<TSource> Timeout<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan dueTime, IScheduler scheduler); IObservable<TSource> Timeout<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan dueTime, IObservable<TSource> other); IObservable<TSource> Timeout<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan dueTime, IObservable<TSource> other, IScheduler scheduler); IObservable<TSource> Timeout<[Nullable(2)] TSource>(IObservable<TSource> source, DateTimeOffset dueTime); IObservable<TSource> Timeout<[Nullable(2)] TSource>(IObservable<TSource> source, DateTimeOffset dueTime, IScheduler scheduler); IObservable<TSource> Timeout<[Nullable(2)] TSource>(IObservable<TSource> source, DateTimeOffset dueTime, IObservable<TSource> other); IObservable<TSource> Timeout<[Nullable(2)] TSource>(IObservable<TSource> source, DateTimeOffset dueTime, IObservable<TSource> other, IScheduler scheduler); IObservable<TSource> Timeout<[Nullable(2)] TSource, [Nullable(2)] TTimeout>(IObservable<TSource> source, Func<TSource, IObservable<TTimeout>> timeoutDurationSelector); IObservable<TSource> Timeout<[Nullable(2)] TSource, [Nullable(2)] TTimeout>(IObservable<TSource> source, Func<TSource, IObservable<TTimeout>> timeoutDurationSelector, IObservable<TSource> other); IObservable<TSource> Timeout<[Nullable(2)] TSource, [Nullable(2)] TTimeout>(IObservable<TSource> source, IObservable<TTimeout> firstTimeout, Func<TSource, IObservable<TTimeout>> timeoutDurationSelector); IObservable<TSource> Timeout<[Nullable(2)] TSource, [Nullable(2)] TTimeout>(IObservable<TSource> source, IObservable<TTimeout> firstTimeout, Func<TSource, IObservable<TTimeout>> timeoutDurationSelector, IObservable<TSource> other); IObservable<long> Timer(TimeSpan dueTime); IObservable<long> Timer(DateTimeOffset dueTime); IObservable<long> Timer(TimeSpan dueTime, TimeSpan period); IObservable<long> Timer(DateTimeOffset dueTime, TimeSpan period); IObservable<long> Timer(TimeSpan dueTime, IScheduler scheduler); IObservable<long> Timer(DateTimeOffset dueTime, IScheduler scheduler); IObservable<long> Timer(TimeSpan dueTime, TimeSpan period, IScheduler scheduler); IObservable<long> Timer(DateTimeOffset dueTime, TimeSpan period, IScheduler scheduler); [return: Nullable(new byte[] { 1, 0, 1 })] IObservable<Timestamped<TSource>> Timestamp<[Nullable(2)] TSource>(IObservable<TSource> source); [return: Nullable(new byte[] { 1, 0, 1 })] IObservable<Timestamped<TSource>> Timestamp<[Nullable(2)] TSource>(IObservable<TSource> source, IScheduler scheduler); IObservable<IObservable<TSource>> Window<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan timeSpan); IObservable<IObservable<TSource>> Window<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan timeSpan, IScheduler scheduler); IObservable<IObservable<TSource>> Window<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan timeSpan, TimeSpan timeShift); IObservable<IObservable<TSource>> Window<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan timeSpan, TimeSpan timeShift, IScheduler scheduler); IObservable<IObservable<TSource>> Window<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan timeSpan, int count); IObservable<IObservable<TSource>> Window<[Nullable(2)] TSource>(IObservable<TSource> source, TimeSpan timeSpan, int count, IScheduler scheduler); IObservable<TResult> CombineLatest<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, Func<T1, T2, TResult> resultSelector); IObservable<TResult> CombineLatest<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, Func<T1, T2, T3, TResult> resultSelector); IObservable<TResult> CombineLatest<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, Func<T1, T2, T3, T4, TResult> resultSelector); IObservable<TResult> CombineLatest<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, Func<T1, T2, T3, T4, T5, TResult> resultSelector); IObservable<TResult> CombineLatest<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] T6, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, Func<T1, T2, T3, T4, T5, T6, TResult> resultSelector); IObservable<TResult> CombineLatest<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] T6, [Nullable(2)] T7, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7, Func<T1, T2, T3, T4, T5, T6, T7, TResult> resultSelector); IObservable<TResult> CombineLatest<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] T6, [Nullable(2)] T7, [Nullable(2)] T8, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7, IObservable<T8> source8, Func<T1, T2, T3, T4, T5, T6, T7, T8, TResult> resultSelector); IObservable<TResult> CombineLatest<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] T6, [Nullable(2)] T7, [Nullable(2)] T8, [Nullable(2)] T9, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7, IObservable<T8> source8, IObservable<T9> source9, Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult> resultSelector); IObservable<TResult> CombineLatest<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] T6, [Nullable(2)] T7, [Nullable(2)] T8, [Nullable(2)] T9, [Nullable(2)] T10, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7, IObservable<T8> source8, IObservable<T9> source9, IObservable<T10> source10, Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult> resultSelector); IObservable<TResult> CombineLatest<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] T6, [Nullable(2)] T7, [Nullable(2)] T8, [Nullable(2)] T9, [Nullable(2)] T10, [Nullable(2)] T11, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7, IObservable<T8> source8, IObservable<T9> source9, IObservable<T10> source10, IObservable<T11> source11, Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult> resultSelector); IObservable<TResult> CombineLatest<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] T6, [Nullable(2)] T7, [Nullable(2)] T8, [Nullable(2)] T9, [Nullable(2)] T10, [Nullable(2)] T11, [Nullable(2)] T12, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7, IObservable<T8> source8, IObservable<T9> source9, IObservable<T10> source10, IObservable<T11> source11, IObservable<T12> source12, Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult> resultSelector); IObservable<TResult> CombineLatest<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] T6, [Nullable(2)] T7, [Nullable(2)] T8, [Nullable(2)] T9, [Nullable(2)] T10, [Nullable(2)] T11, [Nullable(2)] T12, [Nullable(2)] T13, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7, IObservable<T8> source8, IObservable<T9> source9, IObservable<T10> source10, IObservable<T11> source11, IObservable<T12> source12, IObservable<T13> source13, Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult> resultSelector); IObservable<TResult> CombineLatest<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] T6, [Nullable(2)] T7, [Nullable(2)] T8, [Nullable(2)] T9, [Nullable(2)] T10, [Nullable(2)] T11, [Nullable(2)] T12, [Nullable(2)] T13, [Nullable(2)] T14, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7, IObservable<T8> source8, IObservable<T9> source9, IObservable<T10> source10, IObservable<T11> source11, IObservable<T12> source12, IObservable<T13> source13, IObservable<T14> source14, Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult> resultSelector); IObservable<TResult> CombineLatest<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] T6, [Nullable(2)] T7, [Nullable(2)] T8, [Nullable(2)] T9, [Nullable(2)] T10, [Nullable(2)] T11, [Nullable(2)] T12, [Nullable(2)] T13, [Nullable(2)] T14, [Nullable(2)] T15, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7, IObservable<T8> source8, IObservable<T9> source9, IObservable<T10> source10, IObservable<T11> source11, IObservable<T12> source12, IObservable<T13> source13, IObservable<T14> source14, IObservable<T15> source15, Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TResult> resultSelector); IObservable<TResult> CombineLatest<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] T6, [Nullable(2)] T7, [Nullable(2)] T8, [Nullable(2)] T9, [Nullable(2)] T10, [Nullable(2)] T11, [Nullable(2)] T12, [Nullable(2)] T13, [Nullable(2)] T14, [Nullable(2)] T15, [Nullable(2)] T16, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7, IObservable<T8> source8, IObservable<T9> source9, IObservable<T10> source10, IObservable<T11> source11, IObservable<T12> source12, IObservable<T13> source13, IObservable<T14> source14, IObservable<T15> source15, IObservable<T16> source16, Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TResult> resultSelector); IObservable<TResult> Zip<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, Func<T1, T2, TResult> resultSelector); IObservable<TResult> Zip<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, Func<T1, T2, T3, TResult> resultSelector); IObservable<TResult> Zip<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, Func<T1, T2, T3, T4, TResult> resultSelector); IObservable<TResult> Zip<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, Func<T1, T2, T3, T4, T5, TResult> resultSelector); IObservable<TResult> Zip<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] T6, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, Func<T1, T2, T3, T4, T5, T6, TResult> resultSelector); IObservable<TResult> Zip<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] T6, [Nullable(2)] T7, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7, Func<T1, T2, T3, T4, T5, T6, T7, TResult> resultSelector); IObservable<TResult> Zip<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] T6, [Nullable(2)] T7, [Nullable(2)] T8, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7, IObservable<T8> source8, Func<T1, T2, T3, T4, T5, T6, T7, T8, TResult> resultSelector); IObservable<TResult> Zip<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] T6, [Nullable(2)] T7, [Nullable(2)] T8, [Nullable(2)] T9, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7, IObservable<T8> source8, IObservable<T9> source9, Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult> resultSelector); IObservable<TResult> Zip<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] T6, [Nullable(2)] T7, [Nullable(2)] T8, [Nullable(2)] T9, [Nullable(2)] T10, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7, IObservable<T8> source8, IObservable<T9> source9, IObservable<T10> source10, Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult> resultSelector); IObservable<TResult> Zip<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] T6, [Nullable(2)] T7, [Nullable(2)] T8, [Nullable(2)] T9, [Nullable(2)] T10, [Nullable(2)] T11, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7, IObservable<T8> source8, IObservable<T9> source9, IObservable<T10> source10, IObservable<T11> source11, Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult> resultSelector); IObservable<TResult> Zip<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] T6, [Nullable(2)] T7, [Nullable(2)] T8, [Nullable(2)] T9, [Nullable(2)] T10, [Nullable(2)] T11, [Nullable(2)] T12, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7, IObservable<T8> source8, IObservable<T9> source9, IObservable<T10> source10, IObservable<T11> source11, IObservable<T12> source12, Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult> resultSelector); IObservable<TResult> Zip<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] T6, [Nullable(2)] T7, [Nullable(2)] T8, [Nullable(2)] T9, [Nullable(2)] T10, [Nullable(2)] T11, [Nullable(2)] T12, [Nullable(2)] T13, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7, IObservable<T8> source8, IObservable<T9> source9, IObservable<T10> source10, IObservable<T11> source11, IObservable<T12> source12, IObservable<T13> source13, Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult> resultSelector); IObservable<TResult> Zip<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] T6, [Nullable(2)] T7, [Nullable(2)] T8, [Nullable(2)] T9, [Nullable(2)] T10, [Nullable(2)] T11, [Nullable(2)] T12, [Nullable(2)] T13, [Nullable(2)] T14, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7, IObservable<T8> source8, IObservable<T9> source9, IObservable<T10> source10, IObservable<T11> source11, IObservable<T12> source12, IObservable<T13> source13, IObservable<T14> source14, Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult> resultSelector); IObservable<TResult> Zip<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] T6, [Nullable(2)] T7, [Nullable(2)] T8, [Nullable(2)] T9, [Nullable(2)] T10, [Nullable(2)] T11, [Nullable(2)] T12, [Nullable(2)] T13, [Nullable(2)] T14, [Nullable(2)] T15, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7, IObservable<T8> source8, IObservable<T9> source9, IObservable<T10> source10, IObservable<T11> source11, IObservable<T12> source12, IObservable<T13> source13, IObservable<T14> source14, IObservable<T15> source15, Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TResult> resultSelector); IObservable<TResult> Zip<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] T6, [Nullable(2)] T7, [Nullable(2)] T8, [Nullable(2)] T9, [Nullable(2)] T10, [Nullable(2)] T11, [Nullable(2)] T12, [Nullable(2)] T13, [Nullable(2)] T14, [Nullable(2)] T15, [Nullable(2)] T16, [Nullable(2)] TResult>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7, IObservable<T8> source8, IObservable<T9> source9, IObservable<T10> source10, IObservable<T11> source11, IObservable<T12> source12, IObservable<T13> source13, IObservable<T14> source14, IObservable<T15> source15, IObservable<T16> source16, Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TResult> resultSelector); } }