IQueryLanguageEx
interface IQueryLanguageEx
using System.Collections.Generic;
using System.Reactive.Concurrency;
using System.Runtime.CompilerServices;
namespace System.Reactive.Linq
{
[NullableContext(1)]
internal interface IQueryLanguageEx
{
[return: Nullable(new byte[] {
1,
0,
1,
1
})]
IObservable<(T1, T2)> CombineLatest<[Nullable(2)] T1, [Nullable(2)] T2>(IObservable<T1> source1, IObservable<T2> source2);
[return: Nullable(new byte[] {
1,
0,
1,
1,
1
})]
IObservable<(T1, T2, T3)> CombineLatest<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3);
[return: Nullable(new byte[] {
1,
0,
1,
1,
1,
1
})]
IObservable<(T1, T2, T3, T4)> CombineLatest<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4);
[return: Nullable(new byte[] {
1,
0,
1,
1,
1,
1,
1
})]
IObservable<(T1, T2, T3, T4, T5)> CombineLatest<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5);
[return: Nullable(new byte[] {
1,
0,
1,
1,
1,
1,
1,
1
})]
IObservable<(T1, T2, T3, T4, T5, T6)> CombineLatest<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] T6>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6);
[return: Nullable(new byte[] {
1,
0,
1,
1,
1,
1,
1,
1,
1
})]
IObservable<(T1, T2, T3, T4, T5, T6, T7)> CombineLatest<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] T6, [Nullable(2)] T7>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7);
[return: Nullable(new byte[] {
1,
0,
1,
1,
1,
1,
1,
1,
1,
0,
1
})]
IObservable<(T1, T2, T3, T4, T5, T6, T7, T8)> 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>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7, IObservable<T8> source8);
[return: Nullable(new byte[] {
1,
0,
1,
1
})]
IObservable<(T1, T2)> Zip<[Nullable(2)] T1, [Nullable(2)] T2>(IObservable<T1> source1, IObservable<T2> source2);
[return: Nullable(new byte[] {
1,
0,
1,
1,
1
})]
IObservable<(T1, T2, T3)> Zip<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3);
[return: Nullable(new byte[] {
1,
0,
1,
1,
1,
1
})]
IObservable<(T1, T2, T3, T4)> Zip<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4);
[return: Nullable(new byte[] {
1,
0,
1,
1,
1,
1,
1
})]
IObservable<(T1, T2, T3, T4, T5)> Zip<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5);
[return: Nullable(new byte[] {
1,
0,
1,
1,
1,
1,
1,
1
})]
IObservable<(T1, T2, T3, T4, T5, T6)> Zip<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] T6>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6);
[return: Nullable(new byte[] {
1,
0,
1,
1,
1,
1,
1,
1,
1
})]
IObservable<(T1, T2, T3, T4, T5, T6, T7)> Zip<[Nullable(2)] T1, [Nullable(2)] T2, [Nullable(2)] T3, [Nullable(2)] T4, [Nullable(2)] T5, [Nullable(2)] T6, [Nullable(2)] T7>(IObservable<T1> source1, IObservable<T2> source2, IObservable<T3> source3, IObservable<T4> source4, IObservable<T5> source5, IObservable<T6> source6, IObservable<T7> source7);
[return: Nullable(new byte[] {
1,
0,
1,
1,
1,
1,
1,
1,
1,
0,
1
})]
IObservable<(T1, T2, T3, T4, T5, T6, T7, T8)> 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>(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<TResult> Create<[Nullable(2)] TResult>(Func<IObserver<TResult>, IEnumerable<IObservable<object>>> iteratorMethod);
IObservable<Unit> Create(Func<IEnumerable<IObservable<object>>> iteratorMethod);
IObservable<TSource> Expand<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, IObservable<TSource>> selector);
IObservable<TSource> Expand<[Nullable(2)] TSource>(IObservable<TSource> source, Func<TSource, IObservable<TSource>> selector, IScheduler scheduler);
IObservable<TResult> ForkJoin<[Nullable(2)] TFirst, [Nullable(2)] TSecond, [Nullable(2)] TResult>(IObservable<TFirst> first, IObservable<TSecond> second, Func<TFirst, TSecond, TResult> resultSelector);
IObservable<TSource[]> ForkJoin<[Nullable(2)] TSource>(params IObservable<TSource>[] sources);
IObservable<TSource[]> ForkJoin<[Nullable(2)] TSource>(IEnumerable<IObservable<TSource>> sources);
IObservable<TResult> Let<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<IObservable<TSource>, IObservable<TResult>> function);
IObservable<TResult> ManySelect<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<IObservable<TSource>, TResult> selector);
IObservable<TResult> ManySelect<[Nullable(2)] TSource, [Nullable(2)] TResult>(IObservable<TSource> source, Func<IObservable<TSource>, TResult> selector, IScheduler scheduler);
ListObservable<TSource> ToListObservable<[Nullable(2)] TSource>(IObservable<TSource> source);
[return: Nullable(new byte[] {
1,
0,
1,
1
})]
IObservable<(TFirst First, TSecond Second)> WithLatestFrom<[Nullable(2)] TFirst, [Nullable(2)] TSecond>(IObservable<TFirst> first, IObservable<TSecond> second);
[return: Nullable(new byte[] {
1,
0,
1,
1
})]
IObservable<(TFirst First, TSecond Second)> Zip<[Nullable(2)] TFirst, [Nullable(2)] TSecond>(IObservable<TFirst> first, IEnumerable<TSecond> second);
}
}