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