System.Reactive.Linq.ObservableEx
Provides a set of static methods for writing in-memory queries over observable sequences.
namespace System.Reactive.Linq
{
public static class ObservableEx
{
public static IObservable<(TFirst First, TSecond Second)> CombineLatest<[System.Runtime.CompilerServices.Nullable(2)] TFirst, [System.Runtime.CompilerServices.Nullable(2)] TSecond>(this IObservable<TFirst> first, IObservable<TSecond> second);
public static IObservable<(TFirst First, TSecond Second, TThird Third)> CombineLatest<[System.Runtime.CompilerServices.Nullable(2)] TFirst, [System.Runtime.CompilerServices.Nullable(2)] TSecond, [System.Runtime.CompilerServices.Nullable(2)] TThird>(this IObservable<TFirst> first, IObservable<TSecond> second, IObservable<TThird> third);
public static IObservable<(TFirst First, TSecond Second, TThird Third, TFourth Fourth)> CombineLatest<[System.Runtime.CompilerServices.Nullable(2)] TFirst, [System.Runtime.CompilerServices.Nullable(2)] TSecond, [System.Runtime.CompilerServices.Nullable(2)] TThird, [System.Runtime.CompilerServices.Nullable(2)] TFourth>(this IObservable<TFirst> first, IObservable<TSecond> second, IObservable<TThird> third, IObservable<TFourth> fourth);
public static IObservable<(TFirst First, TSecond Second, TThird Third, TFourth Fourth, TFifth Fifth)> CombineLatest<[System.Runtime.CompilerServices.Nullable(2)] TFirst, [System.Runtime.CompilerServices.Nullable(2)] TSecond, [System.Runtime.CompilerServices.Nullable(2)] TThird, [System.Runtime.CompilerServices.Nullable(2)] TFourth, [System.Runtime.CompilerServices.Nullable(2)] TFifth>(this IObservable<TFirst> first, IObservable<TSecond> second, IObservable<TThird> third, IObservable<TFourth> fourth, IObservable<TFifth> fifth);
public static IObservable<(TFirst First, TSecond Second, TThird Third, TFourth Fourth, TFifth Fifth, TSixth Sixth)> CombineLatest<[System.Runtime.CompilerServices.Nullable(2)] TFirst, [System.Runtime.CompilerServices.Nullable(2)] TSecond, [System.Runtime.CompilerServices.Nullable(2)] TThird, [System.Runtime.CompilerServices.Nullable(2)] TFourth, [System.Runtime.CompilerServices.Nullable(2)] TFifth, [System.Runtime.CompilerServices.Nullable(2)] TSixth>(this IObservable<TFirst> first, IObservable<TSecond> second, IObservable<TThird> third, IObservable<TFourth> fourth, IObservable<TFifth> fifth, IObservable<TSixth> sixth);
public static IObservable<(TFirst First, TSecond Second, TThird Third, TFourth Fourth, TFifth Fifth, TSixth Sixth, TSeventh Seventh)> CombineLatest<[System.Runtime.CompilerServices.Nullable(2)] TFirst, [System.Runtime.CompilerServices.Nullable(2)] TSecond, [System.Runtime.CompilerServices.Nullable(2)] TThird, [System.Runtime.CompilerServices.Nullable(2)] TFourth, [System.Runtime.CompilerServices.Nullable(2)] TFifth, [System.Runtime.CompilerServices.Nullable(2)] TSixth, [System.Runtime.CompilerServices.Nullable(2)] TSeventh>(this IObservable<TFirst> first, IObservable<TSecond> second, IObservable<TThird> third, IObservable<TFourth> fourth, IObservable<TFifth> fifth, IObservable<TSixth> sixth, IObservable<TSeventh> seventh);
public static IObservable<(TFirst First, TSecond Second, TThird Third, TFourth Fourth, TFifth Fifth, TSixth Sixth, TSeventh Seventh, TEighth Eighth)> CombineLatest<[System.Runtime.CompilerServices.Nullable(2)] TFirst, [System.Runtime.CompilerServices.Nullable(2)] TSecond, [System.Runtime.CompilerServices.Nullable(2)] TThird, [System.Runtime.CompilerServices.Nullable(2)] TFourth, [System.Runtime.CompilerServices.Nullable(2)] TFifth, [System.Runtime.CompilerServices.Nullable(2)] TSixth, [System.Runtime.CompilerServices.Nullable(2)] TSeventh, [System.Runtime.CompilerServices.Nullable(2)] TEighth>(this IObservable<TFirst> first, IObservable<TSecond> second, IObservable<TThird> third, IObservable<TFourth> fourth, IObservable<TFifth> fifth, IObservable<TSixth> sixth, IObservable<TSeventh> seventh, IObservable<TEighth> eighth);
public static IObservable<(TFirst First, TSecond Second)> WithLatestFrom<[System.Runtime.CompilerServices.Nullable(2)] TFirst, [System.Runtime.CompilerServices.Nullable(2)] TSecond>(this IObservable<TFirst> first, IObservable<TSecond> second);
public static IObservable<(TFirst First, TSecond Second)> Zip<[System.Runtime.CompilerServices.Nullable(2)] TFirst, [System.Runtime.CompilerServices.Nullable(2)] TSecond>(this IObservable<TFirst> first, IEnumerable<TSecond> second);
public static IObservable<(TFirst First, TSecond Second)> Zip<[System.Runtime.CompilerServices.Nullable(2)] TFirst, [System.Runtime.CompilerServices.Nullable(2)] TSecond>(this IObservable<TFirst> first, IObservable<TSecond> second);
public static IObservable<(TFirst First, TSecond Second, TThird Third)> Zip<[System.Runtime.CompilerServices.Nullable(2)] TFirst, [System.Runtime.CompilerServices.Nullable(2)] TSecond, [System.Runtime.CompilerServices.Nullable(2)] TThird>(this IObservable<TFirst> first, IObservable<TSecond> second, IObservable<TThird> third);
public static IObservable<(TFirst First, TSecond Second, TThird Third, TFourth Fourth)> Zip<[System.Runtime.CompilerServices.Nullable(2)] TFirst, [System.Runtime.CompilerServices.Nullable(2)] TSecond, [System.Runtime.CompilerServices.Nullable(2)] TThird, [System.Runtime.CompilerServices.Nullable(2)] TFourth>(this IObservable<TFirst> first, IObservable<TSecond> second, IObservable<TThird> third, IObservable<TFourth> fourth);
public static IObservable<(TFirst First, TSecond Second, TThird Third, TFourth Fourth, TFifth Fifth)> Zip<[System.Runtime.CompilerServices.Nullable(2)] TFirst, [System.Runtime.CompilerServices.Nullable(2)] TSecond, [System.Runtime.CompilerServices.Nullable(2)] TThird, [System.Runtime.CompilerServices.Nullable(2)] TFourth, [System.Runtime.CompilerServices.Nullable(2)] TFifth>(this IObservable<TFirst> first, IObservable<TSecond> second, IObservable<TThird> third, IObservable<TFourth> fourth, IObservable<TFifth> fifth);
public static IObservable<(TFirst First, TSecond Second, TThird Third, TFourth Fourth, TFifth Fifth, TSixth Sixth)> Zip<[System.Runtime.CompilerServices.Nullable(2)] TFirst, [System.Runtime.CompilerServices.Nullable(2)] TSecond, [System.Runtime.CompilerServices.Nullable(2)] TThird, [System.Runtime.CompilerServices.Nullable(2)] TFourth, [System.Runtime.CompilerServices.Nullable(2)] TFifth, [System.Runtime.CompilerServices.Nullable(2)] TSixth>(this IObservable<TFirst> first, IObservable<TSecond> second, IObservable<TThird> third, IObservable<TFourth> fourth, IObservable<TFifth> fifth, IObservable<TSixth> sixth);
public static IObservable<(TFirst First, TSecond Second, TThird Third, TFourth Fourth, TFifth Fifth, TSixth Sixth, TSeventh Seventh)> Zip<[System.Runtime.CompilerServices.Nullable(2)] TFirst, [System.Runtime.CompilerServices.Nullable(2)] TSecond, [System.Runtime.CompilerServices.Nullable(2)] TThird, [System.Runtime.CompilerServices.Nullable(2)] TFourth, [System.Runtime.CompilerServices.Nullable(2)] TFifth, [System.Runtime.CompilerServices.Nullable(2)] TSixth, [System.Runtime.CompilerServices.Nullable(2)] TSeventh>(this IObservable<TFirst> first, IObservable<TSecond> second, IObservable<TThird> third, IObservable<TFourth> fourth, IObservable<TFifth> fifth, IObservable<TSixth> sixth, IObservable<TSeventh> seventh);
public static IObservable<(TFirst First, TSecond Second, TThird Third, TFourth Fourth, TFifth Fifth, TSixth Sixth, TSeventh Seventh, TEighth Eighth)> Zip<[System.Runtime.CompilerServices.Nullable(2)] TFirst, [System.Runtime.CompilerServices.Nullable(2)] TSecond, [System.Runtime.CompilerServices.Nullable(2)] TThird, [System.Runtime.CompilerServices.Nullable(2)] TFourth, [System.Runtime.CompilerServices.Nullable(2)] TFifth, [System.Runtime.CompilerServices.Nullable(2)] TSixth, [System.Runtime.CompilerServices.Nullable(2)] TSeventh, [System.Runtime.CompilerServices.Nullable(2)] TEighth>(this IObservable<TFirst> first, IObservable<TSecond> second, IObservable<TThird> third, IObservable<TFourth> fourth, IObservable<TFifth> fifth, IObservable<TSixth> sixth, IObservable<TSeventh> seventh, IObservable<TEighth> eighth);
public static IObservable<TResult> Create<[System.Runtime.CompilerServices.Nullable(2)] TResult>(Func<IObserver<TResult>, IEnumerable<IObservable<object>>> iteratorMethod);
public static IObservable<Unit> Create(Func<IEnumerable<IObservable<object>>> iteratorMethod);
public static IObservable<TSource> Expand<[System.Runtime.CompilerServices.Nullable(2)] TSource>(this IObservable<TSource> source, Func<TSource, IObservable<TSource>> selector, IScheduler scheduler);
public static IObservable<TSource> Expand<[System.Runtime.CompilerServices.Nullable(2)] TSource>(this IObservable<TSource> source, Func<TSource, IObservable<TSource>> selector);
public static IObservable<TResult> ForkJoin<[System.Runtime.CompilerServices.Nullable(2)] TSource1, [System.Runtime.CompilerServices.Nullable(2)] TSource2, [System.Runtime.CompilerServices.Nullable(2)] TResult>(this IObservable<TSource1> first, IObservable<TSource2> second, Func<TSource1, TSource2, TResult> resultSelector);
public static IObservable<TSource[]> ForkJoin<[System.Runtime.CompilerServices.Nullable(2)] TSource>(params IObservable<TSource>[] sources);
public static IObservable<TSource[]> ForkJoin<[System.Runtime.CompilerServices.Nullable(2)] TSource>(this IEnumerable<IObservable<TSource>> sources);
public static IObservable<TResult> Let<[System.Runtime.CompilerServices.Nullable(2)] TSource, [System.Runtime.CompilerServices.Nullable(2)] TResult>(this IObservable<TSource> source, Func<IObservable<TSource>, IObservable<TResult>> selector);
public static IObservable<TResult> ManySelect<[System.Runtime.CompilerServices.Nullable(2)] TSource, [System.Runtime.CompilerServices.Nullable(2)] TResult>(this IObservable<TSource> source, Func<IObservable<TSource>, TResult> selector, IScheduler scheduler);
public static IObservable<TResult> ManySelect<[System.Runtime.CompilerServices.Nullable(2)] TSource, [System.Runtime.CompilerServices.Nullable(2)] TResult>(this IObservable<TSource> source, Func<IObservable<TSource>, TResult> selector);
public static ListObservable<TSource> ToListObservable<[System.Runtime.CompilerServices.Nullable(2)] TSource>(this IObservable<TSource> source);
}
}