Search Results for

    Show / Hide Table of Contents

    Class ObservableBase<T>

    Abstract base class for implementations of the IObservable<T> interface.

    Inheritance
    Object
    ObservableBase<T>
    AnonymousObservable<T>
    Implements
    IObservable<T>
    Inherited Members
    Object.Equals(Object)
    Object.Equals(Object, Object)
    Object.GetHashCode()
    Object.GetType()
    Object.MemberwiseClone()
    Object.ToString()
    Object.ReferenceEquals(Object, Object)
    Namespace: System.Reactive
    Assembly: System.Reactive.Core.dll
    Syntax
    public abstract class ObservableBase<T> : IObservable<T>
    Type Parameters
    Name Description
    T

    The type of the elements in the sequence.

    Remarks

    If you don't need a named type to create an observable sequence (i.e. you rather need an instance rather than a reusable type), use the Observable.Create method to create an observable sequence with specified subscription behavior.

    Methods

    | Improve this Doc View Source

    Subscribe(IObserver<T>)

    Subscribes the given observer to the observable sequence.

    Declaration
    public IDisposable Subscribe(IObserver<T> observer)
    Parameters
    Type Name Description
    IObserver<T> observer

    Observer that will receive notifications from the observable sequence.

    Returns
    Type Description
    IDisposable

    Disposable object representing an observer's subscription to the observable sequence.

    Exceptions
    Type Condition
    ArgumentNullException

    observer is null.

    | Improve this Doc View Source

    SubscribeCore(IObserver<T>)

    Implement this method with the core subscription logic for the observable sequence.

    Declaration
    protected abstract IDisposable SubscribeCore(IObserver<T> observer)
    Parameters
    Type Name Description
    IObserver<T> observer

    Observer to send notifications to.

    Returns
    Type Description
    IDisposable

    Disposable object representing an observer's subscription to the observable sequence.

    Implements

    System.IObservable<T>

    Extension Methods

    Observable.ForEachAsync<TSource>(IObservable<TSource>, Action<TSource>)
    Observable.ForEachAsync<TSource>(IObservable<TSource>, Action<TSource>, CancellationToken)
    Observable.ForEachAsync<TSource>(IObservable<TSource>, Action<TSource, Int32>)
    Observable.ForEachAsync<TSource>(IObservable<TSource>, Action<TSource, Int32>, CancellationToken)
    Observable.DoWhile<TSource>(IObservable<TSource>, Func<Boolean>)
    Observable.Aggregate<TSource, TAccumulate>(IObservable<TSource>, TAccumulate, Func<TAccumulate, TSource, TAccumulate>)
    Observable.Aggregate<TSource, TAccumulate, TResult>(IObservable<TSource>, TAccumulate, Func<TAccumulate, TSource, TAccumulate>, Func<TAccumulate, TResult>)
    Observable.Aggregate<TSource>(IObservable<TSource>, Func<TSource, TSource, TSource>)
    Observable.All<TSource>(IObservable<TSource>, Func<TSource, Boolean>)
    Observable.Any<TSource>(IObservable<TSource>)
    Observable.Any<TSource>(IObservable<TSource>, Func<TSource, Boolean>)
    Observable.Average<TSource>(IObservable<TSource>, Func<TSource, Decimal>)
    Observable.Average<TSource>(IObservable<TSource>, Func<TSource, Double>)
    Observable.Average<TSource>(IObservable<TSource>, Func<TSource, Single>)
    Observable.Average<TSource>(IObservable<TSource>, Func<TSource, Int32>)
    Observable.Average<TSource>(IObservable<TSource>, Func<TSource, Int64>)
    Observable.Average<TSource>(IObservable<TSource>, Func<TSource, Nullable<Decimal>>)
    Observable.Average<TSource>(IObservable<TSource>, Func<TSource, Nullable<Double>>)
    Observable.Average<TSource>(IObservable<TSource>, Func<TSource, Nullable<Single>>)
    Observable.Average<TSource>(IObservable<TSource>, Func<TSource, Nullable<Int32>>)
    Observable.Average<TSource>(IObservable<TSource>, Func<TSource, Nullable<Int64>>)
    Observable.Contains<TSource>(IObservable<TSource>, TSource)
    Observable.Contains<TSource>(IObservable<TSource>, TSource, IEqualityComparer<TSource>)
    Observable.Count<TSource>(IObservable<TSource>)
    Observable.Count<TSource>(IObservable<TSource>, Func<TSource, Boolean>)
    Observable.ElementAt<TSource>(IObservable<TSource>, Int32)
    Observable.ElementAtOrDefault<TSource>(IObservable<TSource>, Int32)
    Observable.FirstAsync<TSource>(IObservable<TSource>)
    Observable.FirstAsync<TSource>(IObservable<TSource>, Func<TSource, Boolean>)
    Observable.FirstOrDefaultAsync<TSource>(IObservable<TSource>)
    Observable.FirstOrDefaultAsync<TSource>(IObservable<TSource>, Func<TSource, Boolean>)
    Observable.IsEmpty<TSource>(IObservable<TSource>)
    Observable.LastAsync<TSource>(IObservable<TSource>)
    Observable.LastAsync<TSource>(IObservable<TSource>, Func<TSource, Boolean>)
    Observable.LastOrDefaultAsync<TSource>(IObservable<TSource>)
    Observable.LastOrDefaultAsync<TSource>(IObservable<TSource>, Func<TSource, Boolean>)
    Observable.LongCount<TSource>(IObservable<TSource>)
    Observable.LongCount<TSource>(IObservable<TSource>, Func<TSource, Boolean>)
    Observable.Max<TSource>(IObservable<TSource>)
    Observable.Max<TSource>(IObservable<TSource>, IComparer<TSource>)
    Observable.Max<TSource, TResult>(IObservable<TSource>, Func<TSource, TResult>)
    Observable.Max<TSource, TResult>(IObservable<TSource>, Func<TSource, TResult>, IComparer<TResult>)
    Observable.Max<TSource>(IObservable<TSource>, Func<TSource, Double>)
    Observable.Max<TSource>(IObservable<TSource>, Func<TSource, Single>)
    Observable.Max<TSource>(IObservable<TSource>, Func<TSource, Decimal>)
    Observable.Max<TSource>(IObservable<TSource>, Func<TSource, Int32>)
    Observable.Max<TSource>(IObservable<TSource>, Func<TSource, Int64>)
    Observable.Max<TSource>(IObservable<TSource>, Func<TSource, Nullable<Double>>)
    Observable.Max<TSource>(IObservable<TSource>, Func<TSource, Nullable<Single>>)
    Observable.Max<TSource>(IObservable<TSource>, Func<TSource, Nullable<Decimal>>)
    Observable.Max<TSource>(IObservable<TSource>, Func<TSource, Nullable<Int32>>)
    Observable.Max<TSource>(IObservable<TSource>, Func<TSource, Nullable<Int64>>)
    Observable.MaxBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>)
    Observable.MaxBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>, IComparer<TKey>)
    Observable.Min<TSource>(IObservable<TSource>)
    Observable.Min<TSource>(IObservable<TSource>, IComparer<TSource>)
    Observable.Min<TSource, TResult>(IObservable<TSource>, Func<TSource, TResult>)
    Observable.Min<TSource, TResult>(IObservable<TSource>, Func<TSource, TResult>, IComparer<TResult>)
    Observable.Min<TSource>(IObservable<TSource>, Func<TSource, Double>)
    Observable.Min<TSource>(IObservable<TSource>, Func<TSource, Single>)
    Observable.Min<TSource>(IObservable<TSource>, Func<TSource, Decimal>)
    Observable.Min<TSource>(IObservable<TSource>, Func<TSource, Int32>)
    Observable.Min<TSource>(IObservable<TSource>, Func<TSource, Int64>)
    Observable.Min<TSource>(IObservable<TSource>, Func<TSource, Nullable<Double>>)
    Observable.Min<TSource>(IObservable<TSource>, Func<TSource, Nullable<Single>>)
    Observable.Min<TSource>(IObservable<TSource>, Func<TSource, Nullable<Decimal>>)
    Observable.Min<TSource>(IObservable<TSource>, Func<TSource, Nullable<Int32>>)
    Observable.Min<TSource>(IObservable<TSource>, Func<TSource, Nullable<Int64>>)
    Observable.MinBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>)
    Observable.MinBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>, IComparer<TKey>)
    Observable.SequenceEqual<TSource>(IObservable<TSource>, IObservable<TSource>)
    Observable.SequenceEqual<TSource>(IObservable<TSource>, IObservable<TSource>, IEqualityComparer<TSource>)
    Observable.SequenceEqual<TSource>(IObservable<TSource>, IEnumerable<TSource>)
    Observable.SequenceEqual<TSource>(IObservable<TSource>, IEnumerable<TSource>, IEqualityComparer<TSource>)
    Observable.SingleAsync<TSource>(IObservable<TSource>)
    Observable.SingleAsync<TSource>(IObservable<TSource>, Func<TSource, Boolean>)
    Observable.SingleOrDefaultAsync<TSource>(IObservable<TSource>)
    Observable.SingleOrDefaultAsync<TSource>(IObservable<TSource>, Func<TSource, Boolean>)
    Observable.Sum<TSource>(IObservable<TSource>, Func<TSource, Double>)
    Observable.Sum<TSource>(IObservable<TSource>, Func<TSource, Single>)
    Observable.Sum<TSource>(IObservable<TSource>, Func<TSource, Decimal>)
    Observable.Sum<TSource>(IObservable<TSource>, Func<TSource, Int32>)
    Observable.Sum<TSource>(IObservable<TSource>, Func<TSource, Int64>)
    Observable.Sum<TSource>(IObservable<TSource>, Func<TSource, Nullable<Double>>)
    Observable.Sum<TSource>(IObservable<TSource>, Func<TSource, Nullable<Single>>)
    Observable.Sum<TSource>(IObservable<TSource>, Func<TSource, Nullable<Decimal>>)
    Observable.Sum<TSource>(IObservable<TSource>, Func<TSource, Nullable<Int32>>)
    Observable.Sum<TSource>(IObservable<TSource>, Func<TSource, Nullable<Int64>>)
    Observable.ToArray<TSource>(IObservable<TSource>)
    Observable.ToDictionary<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>)
    Observable.ToDictionary<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>, IEqualityComparer<TKey>)
    Observable.ToDictionary<TSource, TKey, TElement>(IObservable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>)
    Observable.ToDictionary<TSource, TKey, TElement>(IObservable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>, IEqualityComparer<TKey>)
    Observable.ToList<TSource>(IObservable<TSource>)
    Observable.ToLookup<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>)
    Observable.ToLookup<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>, IEqualityComparer<TKey>)
    Observable.ToLookup<TSource, TKey, TElement>(IObservable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>)
    Observable.ToLookup<TSource, TKey, TElement>(IObservable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>, IEqualityComparer<TKey>)
    Observable.Multicast<TSource, TResult>(IObservable<TSource>, ISubject<TSource, TResult>)
    Observable.Multicast<TSource, TIntermediate, TResult>(IObservable<TSource>, Func<ISubject<TSource, TIntermediate>>, Func<IObservable<TIntermediate>, IObservable<TResult>>)
    Observable.Publish<TSource>(IObservable<TSource>)
    Observable.Publish<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>)
    Observable.Publish<TSource>(IObservable<TSource>, TSource)
    Observable.Publish<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, TSource)
    Observable.PublishLast<TSource>(IObservable<TSource>)
    Observable.PublishLast<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>)
    Observable.Replay<TSource>(IObservable<TSource>)
    Observable.Replay<TSource>(IObservable<TSource>, IScheduler)
    Observable.Replay<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>)
    Observable.Replay<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, IScheduler)
    Observable.Replay<TSource>(IObservable<TSource>, TimeSpan)
    Observable.Replay<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, TimeSpan)
    Observable.Replay<TSource>(IObservable<TSource>, TimeSpan, IScheduler)
    Observable.Replay<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, TimeSpan, IScheduler)
    Observable.Replay<TSource>(IObservable<TSource>, Int32, IScheduler)
    Observable.Replay<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, Int32, IScheduler)
    Observable.Replay<TSource>(IObservable<TSource>, Int32)
    Observable.Replay<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, Int32)
    Observable.Replay<TSource>(IObservable<TSource>, Int32, TimeSpan)
    Observable.Replay<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, Int32, TimeSpan)
    Observable.Replay<TSource>(IObservable<TSource>, Int32, TimeSpan, IScheduler)
    Observable.Replay<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, Int32, TimeSpan, IScheduler)
    Observable.Chunkify<TSource>(IObservable<TSource>)
    Observable.Collect<TSource, TResult>(IObservable<TSource>, Func<TResult>, Func<TResult, TSource, TResult>)
    Observable.Collect<TSource, TResult>(IObservable<TSource>, Func<TResult>, Func<TResult, TSource, TResult>, Func<TResult, TResult>)
    Observable.First<TSource>(IObservable<TSource>)
    Observable.First<TSource>(IObservable<TSource>, Func<TSource, Boolean>)
    Observable.FirstOrDefault<TSource>(IObservable<TSource>)
    Observable.FirstOrDefault<TSource>(IObservable<TSource>, Func<TSource, Boolean>)
    Observable.ForEach<TSource>(IObservable<TSource>, Action<TSource>)
    Observable.ForEach<TSource>(IObservable<TSource>, Action<TSource, Int32>)
    Observable.GetEnumerator<TSource>(IObservable<TSource>)
    Observable.Last<TSource>(IObservable<TSource>)
    Observable.Last<TSource>(IObservable<TSource>, Func<TSource, Boolean>)
    Observable.LastOrDefault<TSource>(IObservable<TSource>)
    Observable.LastOrDefault<TSource>(IObservable<TSource>, Func<TSource, Boolean>)
    Observable.Latest<TSource>(IObservable<TSource>)
    Observable.MostRecent<TSource>(IObservable<TSource>, TSource)
    Observable.Next<TSource>(IObservable<TSource>)
    Observable.Single<TSource>(IObservable<TSource>)
    Observable.Single<TSource>(IObservable<TSource>, Func<TSource, Boolean>)
    Observable.SingleOrDefault<TSource>(IObservable<TSource>)
    Observable.SingleOrDefault<TSource>(IObservable<TSource>, Func<TSource, Boolean>)
    Observable.Wait<TSource>(IObservable<TSource>)
    Observable.ObserveOn<TSource>(IObservable<TSource>, IScheduler)
    Observable.ObserveOn<TSource>(IObservable<TSource>, SynchronizationContext)
    Observable.SubscribeOn<TSource>(IObservable<TSource>, IScheduler)
    Observable.SubscribeOn<TSource>(IObservable<TSource>, SynchronizationContext)
    Observable.Synchronize<TSource>(IObservable<TSource>)
    Observable.Synchronize<TSource>(IObservable<TSource>, Object)
    Observable.ToEnumerable<TSource>(IObservable<TSource>)
    Observable.ToEvent<TSource>(IObservable<TSource>)
    Observable.And<TLeft, TRight>(IObservable<TLeft>, IObservable<TRight>)
    Observable.Then<TSource, TResult>(IObservable<TSource>, Func<TSource, TResult>)
    Observable.Amb<TSource>(IObservable<TSource>, IObservable<TSource>)
    Observable.Buffer<TSource, TBufferClosing>(IObservable<TSource>, Func<IObservable<TBufferClosing>>)
    Observable.Buffer<TSource, TBufferOpening, TBufferClosing>(IObservable<TSource>, IObservable<TBufferOpening>, Func<TBufferOpening, IObservable<TBufferClosing>>)
    Observable.Buffer<TSource, TBufferBoundary>(IObservable<TSource>, IObservable<TBufferBoundary>)
    Observable.Catch<TSource, TException>(IObservable<TSource>, Func<TException, IObservable<TSource>>)
    Observable.Catch<TSource>(IObservable<TSource>, IObservable<TSource>)
    Observable.CombineLatest<TSource1, TSource2, TResult>(IObservable<TSource1>, IObservable<TSource2>, Func<TSource1, TSource2, TResult>)
    Observable.CombineLatest<TSource1, TSource2, TSource3, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, Func<TSource1, TSource2, TSource3, TResult>)
    Observable.CombineLatest<TSource1, TSource2, TSource3, TSource4, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, IObservable<TSource4>, Func<TSource1, TSource2, TSource3, TSource4, TResult>)
    Observable.CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, IObservable<TSource4>, IObservable<TSource5>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TResult>)
    Observable.CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, IObservable<TSource4>, IObservable<TSource5>, IObservable<TSource6>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TResult>)
    Observable.CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, IObservable<TSource4>, IObservable<TSource5>, IObservable<TSource6>, IObservable<TSource7>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TResult>)
    Observable.CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, IObservable<TSource4>, IObservable<TSource5>, IObservable<TSource6>, IObservable<TSource7>, IObservable<TSource8>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TResult>)
    Observable.CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, IObservable<TSource4>, IObservable<TSource5>, IObservable<TSource6>, IObservable<TSource7>, IObservable<TSource8>, IObservable<TSource9>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TResult>)
    Observable.CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, IObservable<TSource4>, IObservable<TSource5>, IObservable<TSource6>, IObservable<TSource7>, IObservable<TSource8>, IObservable<TSource9>, IObservable<TSource10>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TResult>)
    Observable.CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, IObservable<TSource4>, IObservable<TSource5>, IObservable<TSource6>, IObservable<TSource7>, IObservable<TSource8>, IObservable<TSource9>, IObservable<TSource10>, IObservable<TSource11>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TResult>)
    Observable.CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, IObservable<TSource4>, IObservable<TSource5>, IObservable<TSource6>, IObservable<TSource7>, IObservable<TSource8>, IObservable<TSource9>, IObservable<TSource10>, IObservable<TSource11>, IObservable<TSource12>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TResult>)
    Observable.CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, IObservable<TSource4>, IObservable<TSource5>, IObservable<TSource6>, IObservable<TSource7>, IObservable<TSource8>, IObservable<TSource9>, IObservable<TSource10>, IObservable<TSource11>, IObservable<TSource12>, IObservable<TSource13>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TResult>)
    Observable.CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, IObservable<TSource4>, IObservable<TSource5>, IObservable<TSource6>, IObservable<TSource7>, IObservable<TSource8>, IObservable<TSource9>, IObservable<TSource10>, IObservable<TSource11>, IObservable<TSource12>, IObservable<TSource13>, IObservable<TSource14>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TResult>)
    Observable.CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, IObservable<TSource4>, IObservable<TSource5>, IObservable<TSource6>, IObservable<TSource7>, IObservable<TSource8>, IObservable<TSource9>, IObservable<TSource10>, IObservable<TSource11>, IObservable<TSource12>, IObservable<TSource13>, IObservable<TSource14>, IObservable<TSource15>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TResult>)
    Observable.CombineLatest<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TSource16, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, IObservable<TSource4>, IObservable<TSource5>, IObservable<TSource6>, IObservable<TSource7>, IObservable<TSource8>, IObservable<TSource9>, IObservable<TSource10>, IObservable<TSource11>, IObservable<TSource12>, IObservable<TSource13>, IObservable<TSource14>, IObservable<TSource15>, IObservable<TSource16>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TSource16, TResult>)
    Observable.Concat<TSource>(IObservable<TSource>, IObservable<TSource>)
    Observable.Merge<TSource>(IObservable<TSource>, IObservable<TSource>)
    Observable.Merge<TSource>(IObservable<TSource>, IObservable<TSource>, IScheduler)
    Observable.OnErrorResumeNext<TSource>(IObservable<TSource>, IObservable<TSource>)
    Observable.SkipUntil<TSource, TOther>(IObservable<TSource>, IObservable<TOther>)
    Observable.TakeUntil<TSource, TOther>(IObservable<TSource>, IObservable<TOther>)
    Observable.Window<TSource, TWindowClosing>(IObservable<TSource>, Func<IObservable<TWindowClosing>>)
    Observable.Window<TSource, TWindowOpening, TWindowClosing>(IObservable<TSource>, IObservable<TWindowOpening>, Func<TWindowOpening, IObservable<TWindowClosing>>)
    Observable.Window<TSource, TWindowBoundary>(IObservable<TSource>, IObservable<TWindowBoundary>)
    Observable.Zip<TSource1, TSource2, TResult>(IObservable<TSource1>, IObservable<TSource2>, Func<TSource1, TSource2, TResult>)
    Observable.Zip<TSource1, TSource2, TSource3, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, Func<TSource1, TSource2, TSource3, TResult>)
    Observable.Zip<TSource1, TSource2, TSource3, TSource4, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, IObservable<TSource4>, Func<TSource1, TSource2, TSource3, TSource4, TResult>)
    Observable.Zip<TSource1, TSource2, TSource3, TSource4, TSource5, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, IObservable<TSource4>, IObservable<TSource5>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TResult>)
    Observable.Zip<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, IObservable<TSource4>, IObservable<TSource5>, IObservable<TSource6>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TResult>)
    Observable.Zip<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, IObservable<TSource4>, IObservable<TSource5>, IObservable<TSource6>, IObservable<TSource7>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TResult>)
    Observable.Zip<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, IObservable<TSource4>, IObservable<TSource5>, IObservable<TSource6>, IObservable<TSource7>, IObservable<TSource8>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TResult>)
    Observable.Zip<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, IObservable<TSource4>, IObservable<TSource5>, IObservable<TSource6>, IObservable<TSource7>, IObservable<TSource8>, IObservable<TSource9>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TResult>)
    Observable.Zip<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, IObservable<TSource4>, IObservable<TSource5>, IObservable<TSource6>, IObservable<TSource7>, IObservable<TSource8>, IObservable<TSource9>, IObservable<TSource10>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TResult>)
    Observable.Zip<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, IObservable<TSource4>, IObservable<TSource5>, IObservable<TSource6>, IObservable<TSource7>, IObservable<TSource8>, IObservable<TSource9>, IObservable<TSource10>, IObservable<TSource11>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TResult>)
    Observable.Zip<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, IObservable<TSource4>, IObservable<TSource5>, IObservable<TSource6>, IObservable<TSource7>, IObservable<TSource8>, IObservable<TSource9>, IObservable<TSource10>, IObservable<TSource11>, IObservable<TSource12>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TResult>)
    Observable.Zip<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, IObservable<TSource4>, IObservable<TSource5>, IObservable<TSource6>, IObservable<TSource7>, IObservable<TSource8>, IObservable<TSource9>, IObservable<TSource10>, IObservable<TSource11>, IObservable<TSource12>, IObservable<TSource13>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TResult>)
    Observable.Zip<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, IObservable<TSource4>, IObservable<TSource5>, IObservable<TSource6>, IObservable<TSource7>, IObservable<TSource8>, IObservable<TSource9>, IObservable<TSource10>, IObservable<TSource11>, IObservable<TSource12>, IObservable<TSource13>, IObservable<TSource14>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TResult>)
    Observable.Zip<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, IObservable<TSource4>, IObservable<TSource5>, IObservable<TSource6>, IObservable<TSource7>, IObservable<TSource8>, IObservable<TSource9>, IObservable<TSource10>, IObservable<TSource11>, IObservable<TSource12>, IObservable<TSource13>, IObservable<TSource14>, IObservable<TSource15>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TResult>)
    Observable.Zip<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TSource16, TResult>(IObservable<TSource1>, IObservable<TSource2>, IObservable<TSource3>, IObservable<TSource4>, IObservable<TSource5>, IObservable<TSource6>, IObservable<TSource7>, IObservable<TSource8>, IObservable<TSource9>, IObservable<TSource10>, IObservable<TSource11>, IObservable<TSource12>, IObservable<TSource13>, IObservable<TSource14>, IObservable<TSource15>, IObservable<TSource16>, Func<TSource1, TSource2, TSource3, TSource4, TSource5, TSource6, TSource7, TSource8, TSource9, TSource10, TSource11, TSource12, TSource13, TSource14, TSource15, TSource16, TResult>)
    Observable.Zip<TSource1, TSource2, TResult>(IObservable<TSource1>, IEnumerable<TSource2>, Func<TSource1, TSource2, TResult>)
    Observable.AsObservable<TSource>(IObservable<TSource>)
    Observable.Buffer<TSource>(IObservable<TSource>, Int32)
    Observable.Buffer<TSource>(IObservable<TSource>, Int32, Int32)
    Observable.DistinctUntilChanged<TSource>(IObservable<TSource>)
    Observable.DistinctUntilChanged<TSource>(IObservable<TSource>, IEqualityComparer<TSource>)
    Observable.DistinctUntilChanged<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>)
    Observable.DistinctUntilChanged<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>, IEqualityComparer<TKey>)
    Observable.Do<TSource>(IObservable<TSource>, Action<TSource>)
    Observable.Do<TSource>(IObservable<TSource>, Action<TSource>, Action)
    Observable.Do<TSource>(IObservable<TSource>, Action<TSource>, Action<Exception>)
    Observable.Do<TSource>(IObservable<TSource>, Action<TSource>, Action<Exception>, Action)
    Observable.Do<TSource>(IObservable<TSource>, IObserver<TSource>)
    Observable.Finally<TSource>(IObservable<TSource>, Action)
    Observable.IgnoreElements<TSource>(IObservable<TSource>)
    Observable.Materialize<TSource>(IObservable<TSource>)
    Observable.Repeat<TSource>(IObservable<TSource>)
    Observable.Repeat<TSource>(IObservable<TSource>, Int32)
    Observable.Retry<TSource>(IObservable<TSource>)
    Observable.Retry<TSource>(IObservable<TSource>, Int32)
    Observable.Scan<TSource, TAccumulate>(IObservable<TSource>, TAccumulate, Func<TAccumulate, TSource, TAccumulate>)
    Observable.Scan<TSource>(IObservable<TSource>, Func<TSource, TSource, TSource>)
    Observable.SkipLast<TSource>(IObservable<TSource>, Int32)
    Observable.StartWith<TSource>(IObservable<TSource>, TSource[])
    Observable.StartWith<TSource>(IObservable<TSource>, IEnumerable<TSource>)
    Observable.StartWith<TSource>(IObservable<TSource>, IScheduler, TSource[])
    Observable.StartWith<TSource>(IObservable<TSource>, IScheduler, IEnumerable<TSource>)
    Observable.TakeLast<TSource>(IObservable<TSource>, Int32)
    Observable.TakeLast<TSource>(IObservable<TSource>, Int32, IScheduler)
    Observable.TakeLastBuffer<TSource>(IObservable<TSource>, Int32)
    Observable.Window<TSource>(IObservable<TSource>, Int32)
    Observable.Window<TSource>(IObservable<TSource>, Int32, Int32)
    Observable.DefaultIfEmpty<TSource>(IObservable<TSource>)
    Observable.DefaultIfEmpty<TSource>(IObservable<TSource>, TSource)
    Observable.Distinct<TSource>(IObservable<TSource>)
    Observable.Distinct<TSource>(IObservable<TSource>, IEqualityComparer<TSource>)
    Observable.Distinct<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>)
    Observable.Distinct<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>, IEqualityComparer<TKey>)
    Observable.GroupBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>)
    Observable.GroupBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>, IEqualityComparer<TKey>)
    Observable.GroupBy<TSource, TKey, TElement>(IObservable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>)
    Observable.GroupBy<TSource, TKey, TElement>(IObservable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>, IEqualityComparer<TKey>)
    Observable.GroupBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>, Int32)
    Observable.GroupBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>, Int32, IEqualityComparer<TKey>)
    Observable.GroupBy<TSource, TKey, TElement>(IObservable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>, Int32)
    Observable.GroupBy<TSource, TKey, TElement>(IObservable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>, Int32, IEqualityComparer<TKey>)
    Observable.GroupByUntil<TSource, TKey, TElement, TDuration>(IObservable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>, Func<IGroupedObservable<TKey, TElement>, IObservable<TDuration>>, IEqualityComparer<TKey>)
    Observable.GroupByUntil<TSource, TKey, TElement, TDuration>(IObservable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>, Func<IGroupedObservable<TKey, TElement>, IObservable<TDuration>>)
    Observable.GroupByUntil<TSource, TKey, TDuration>(IObservable<TSource>, Func<TSource, TKey>, Func<IGroupedObservable<TKey, TSource>, IObservable<TDuration>>, IEqualityComparer<TKey>)
    Observable.GroupByUntil<TSource, TKey, TDuration>(IObservable<TSource>, Func<TSource, TKey>, Func<IGroupedObservable<TKey, TSource>, IObservable<TDuration>>)
    Observable.GroupByUntil<TSource, TKey, TElement, TDuration>(IObservable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>, Func<IGroupedObservable<TKey, TElement>, IObservable<TDuration>>, Int32, IEqualityComparer<TKey>)
    Observable.GroupByUntil<TSource, TKey, TElement, TDuration>(IObservable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>, Func<IGroupedObservable<TKey, TElement>, IObservable<TDuration>>, Int32)
    Observable.GroupByUntil<TSource, TKey, TDuration>(IObservable<TSource>, Func<TSource, TKey>, Func<IGroupedObservable<TKey, TSource>, IObservable<TDuration>>, Int32, IEqualityComparer<TKey>)
    Observable.GroupByUntil<TSource, TKey, TDuration>(IObservable<TSource>, Func<TSource, TKey>, Func<IGroupedObservable<TKey, TSource>, IObservable<TDuration>>, Int32)
    Observable.GroupJoin<TLeft, TRight, TLeftDuration, TRightDuration, TResult>(IObservable<TLeft>, IObservable<TRight>, Func<TLeft, IObservable<TLeftDuration>>, Func<TRight, IObservable<TRightDuration>>, Func<TLeft, IObservable<TRight>, TResult>)
    Observable.Join<TLeft, TRight, TLeftDuration, TRightDuration, TResult>(IObservable<TLeft>, IObservable<TRight>, Func<TLeft, IObservable<TLeftDuration>>, Func<TRight, IObservable<TRightDuration>>, Func<TLeft, TRight, TResult>)
    Observable.Select<TSource, TResult>(IObservable<TSource>, Func<TSource, TResult>)
    Observable.Select<TSource, TResult>(IObservable<TSource>, Func<TSource, Int32, TResult>)
    Observable.SelectMany<TSource, TOther>(IObservable<TSource>, IObservable<TOther>)
    Observable.SelectMany<TSource, TResult>(IObservable<TSource>, Func<TSource, IObservable<TResult>>)
    Observable.SelectMany<TSource, TResult>(IObservable<TSource>, Func<TSource, Int32, IObservable<TResult>>)
    Observable.SelectMany<TSource, TResult>(IObservable<TSource>, Func<TSource, Task<TResult>>)
    Observable.SelectMany<TSource, TResult>(IObservable<TSource>, Func<TSource, Int32, Task<TResult>>)
    Observable.SelectMany<TSource, TResult>(IObservable<TSource>, Func<TSource, CancellationToken, Task<TResult>>)
    Observable.SelectMany<TSource, TResult>(IObservable<TSource>, Func<TSource, Int32, CancellationToken, Task<TResult>>)
    Observable.SelectMany<TSource, TCollection, TResult>(IObservable<TSource>, Func<TSource, IObservable<TCollection>>, Func<TSource, TCollection, TResult>)
    Observable.SelectMany<TSource, TCollection, TResult>(IObservable<TSource>, Func<TSource, Int32, IObservable<TCollection>>, Func<TSource, Int32, TCollection, Int32, TResult>)
    Observable.SelectMany<TSource, TTaskResult, TResult>(IObservable<TSource>, Func<TSource, Task<TTaskResult>>, Func<TSource, TTaskResult, TResult>)
    Observable.SelectMany<TSource, TTaskResult, TResult>(IObservable<TSource>, Func<TSource, Int32, Task<TTaskResult>>, Func<TSource, Int32, TTaskResult, TResult>)
    Observable.SelectMany<TSource, TTaskResult, TResult>(IObservable<TSource>, Func<TSource, CancellationToken, Task<TTaskResult>>, Func<TSource, TTaskResult, TResult>)
    Observable.SelectMany<TSource, TTaskResult, TResult>(IObservable<TSource>, Func<TSource, Int32, CancellationToken, Task<TTaskResult>>, Func<TSource, Int32, TTaskResult, TResult>)
    Observable.SelectMany<TSource, TResult>(IObservable<TSource>, Func<TSource, IObservable<TResult>>, Func<Exception, IObservable<TResult>>, Func<IObservable<TResult>>)
    Observable.SelectMany<TSource, TResult>(IObservable<TSource>, Func<TSource, Int32, IObservable<TResult>>, Func<Exception, IObservable<TResult>>, Func<IObservable<TResult>>)
    Observable.SelectMany<TSource, TResult>(IObservable<TSource>, Func<TSource, IEnumerable<TResult>>)
    Observable.SelectMany<TSource, TResult>(IObservable<TSource>, Func<TSource, Int32, IEnumerable<TResult>>)
    Observable.SelectMany<TSource, TCollection, TResult>(IObservable<TSource>, Func<TSource, IEnumerable<TCollection>>, Func<TSource, TCollection, TResult>)
    Observable.SelectMany<TSource, TCollection, TResult>(IObservable<TSource>, Func<TSource, Int32, IEnumerable<TCollection>>, Func<TSource, Int32, TCollection, Int32, TResult>)
    Observable.Skip<TSource>(IObservable<TSource>, Int32)
    Observable.SkipWhile<TSource>(IObservable<TSource>, Func<TSource, Boolean>)
    Observable.SkipWhile<TSource>(IObservable<TSource>, Func<TSource, Int32, Boolean>)
    Observable.Take<TSource>(IObservable<TSource>, Int32)
    Observable.Take<TSource>(IObservable<TSource>, Int32, IScheduler)
    Observable.TakeWhile<TSource>(IObservable<TSource>, Func<TSource, Boolean>)
    Observable.TakeWhile<TSource>(IObservable<TSource>, Func<TSource, Int32, Boolean>)
    Observable.Where<TSource>(IObservable<TSource>, Func<TSource, Boolean>)
    Observable.Where<TSource>(IObservable<TSource>, Func<TSource, Int32, Boolean>)
    Observable.Buffer<TSource>(IObservable<TSource>, TimeSpan)
    Observable.Buffer<TSource>(IObservable<TSource>, TimeSpan, IScheduler)
    Observable.Buffer<TSource>(IObservable<TSource>, TimeSpan, TimeSpan)
    Observable.Buffer<TSource>(IObservable<TSource>, TimeSpan, TimeSpan, IScheduler)
    Observable.Buffer<TSource>(IObservable<TSource>, TimeSpan, Int32)
    Observable.Buffer<TSource>(IObservable<TSource>, TimeSpan, Int32, IScheduler)
    Observable.Delay<TSource>(IObservable<TSource>, TimeSpan)
    Observable.Delay<TSource>(IObservable<TSource>, TimeSpan, IScheduler)
    Observable.Delay<TSource>(IObservable<TSource>, DateTimeOffset)
    Observable.Delay<TSource>(IObservable<TSource>, DateTimeOffset, IScheduler)
    Observable.Delay<TSource, TDelay>(IObservable<TSource>, Func<TSource, IObservable<TDelay>>)
    Observable.Delay<TSource, TDelay>(IObservable<TSource>, IObservable<TDelay>, Func<TSource, IObservable<TDelay>>)
    Observable.DelaySubscription<TSource>(IObservable<TSource>, TimeSpan)
    Observable.DelaySubscription<TSource>(IObservable<TSource>, TimeSpan, IScheduler)
    Observable.DelaySubscription<TSource>(IObservable<TSource>, DateTimeOffset)
    Observable.DelaySubscription<TSource>(IObservable<TSource>, DateTimeOffset, IScheduler)
    Observable.Sample<TSource>(IObservable<TSource>, TimeSpan)
    Observable.Sample<TSource>(IObservable<TSource>, TimeSpan, IScheduler)
    Observable.Sample<TSource, TSample>(IObservable<TSource>, IObservable<TSample>)
    Observable.Skip<TSource>(IObservable<TSource>, TimeSpan)
    Observable.Skip<TSource>(IObservable<TSource>, TimeSpan, IScheduler)
    Observable.SkipLast<TSource>(IObservable<TSource>, TimeSpan)
    Observable.SkipLast<TSource>(IObservable<TSource>, TimeSpan, IScheduler)
    Observable.SkipUntil<TSource>(IObservable<TSource>, DateTimeOffset)
    Observable.SkipUntil<TSource>(IObservable<TSource>, DateTimeOffset, IScheduler)
    Observable.Take<TSource>(IObservable<TSource>, TimeSpan)
    Observable.Take<TSource>(IObservable<TSource>, TimeSpan, IScheduler)
    Observable.TakeLast<TSource>(IObservable<TSource>, TimeSpan)
    Observable.TakeLast<TSource>(IObservable<TSource>, TimeSpan, IScheduler)
    Observable.TakeLast<TSource>(IObservable<TSource>, TimeSpan, IScheduler, IScheduler)
    Observable.TakeLastBuffer<TSource>(IObservable<TSource>, TimeSpan)
    Observable.TakeLastBuffer<TSource>(IObservable<TSource>, TimeSpan, IScheduler)
    Observable.TakeUntil<TSource>(IObservable<TSource>, DateTimeOffset)
    Observable.TakeUntil<TSource>(IObservable<TSource>, DateTimeOffset, IScheduler)
    Observable.Throttle<TSource>(IObservable<TSource>, TimeSpan)
    Observable.Throttle<TSource>(IObservable<TSource>, TimeSpan, IScheduler)
    Observable.Throttle<TSource, TThrottle>(IObservable<TSource>, Func<TSource, IObservable<TThrottle>>)
    Observable.TimeInterval<TSource>(IObservable<TSource>)
    Observable.TimeInterval<TSource>(IObservable<TSource>, IScheduler)
    Observable.Timeout<TSource>(IObservable<TSource>, TimeSpan)
    Observable.Timeout<TSource>(IObservable<TSource>, TimeSpan, IScheduler)
    Observable.Timeout<TSource>(IObservable<TSource>, TimeSpan, IObservable<TSource>)
    Observable.Timeout<TSource>(IObservable<TSource>, TimeSpan, IObservable<TSource>, IScheduler)
    Observable.Timeout<TSource>(IObservable<TSource>, DateTimeOffset)
    Observable.Timeout<TSource>(IObservable<TSource>, DateTimeOffset, IScheduler)
    Observable.Timeout<TSource>(IObservable<TSource>, DateTimeOffset, IObservable<TSource>)
    Observable.Timeout<TSource>(IObservable<TSource>, DateTimeOffset, IObservable<TSource>, IScheduler)
    Observable.Timeout<TSource, TTimeout>(IObservable<TSource>, Func<TSource, IObservable<TTimeout>>)
    Observable.Timeout<TSource, TTimeout>(IObservable<TSource>, Func<TSource, IObservable<TTimeout>>, IObservable<TSource>)
    Observable.Timeout<TSource, TTimeout>(IObservable<TSource>, IObservable<TTimeout>, Func<TSource, IObservable<TTimeout>>)
    Observable.Timeout<TSource, TTimeout>(IObservable<TSource>, IObservable<TTimeout>, Func<TSource, IObservable<TTimeout>>, IObservable<TSource>)
    Observable.Timestamp<TSource>(IObservable<TSource>)
    Observable.Timestamp<TSource>(IObservable<TSource>, IScheduler)
    Observable.Window<TSource>(IObservable<TSource>, TimeSpan)
    Observable.Window<TSource>(IObservable<TSource>, TimeSpan, IScheduler)
    Observable.Window<TSource>(IObservable<TSource>, TimeSpan, TimeSpan)
    Observable.Window<TSource>(IObservable<TSource>, TimeSpan, TimeSpan, IScheduler)
    Observable.Window<TSource>(IObservable<TSource>, TimeSpan, Int32)
    Observable.Window<TSource>(IObservable<TSource>, TimeSpan, Int32, IScheduler)
    TaskObservableExtensions.ToTask<TResult>(IObservable<TResult>)
    TaskObservableExtensions.ToTask<TResult>(IObservable<TResult>, Object)
    TaskObservableExtensions.ToTask<TResult>(IObservable<TResult>, CancellationToken)
    TaskObservableExtensions.ToTask<TResult>(IObservable<TResult>, CancellationToken, Object)
    ObservableExtensions.Subscribe<T>(IObservable<T>)
    ObservableExtensions.Subscribe<T>(IObservable<T>, Action<T>)
    ObservableExtensions.Subscribe<T>(IObservable<T>, Action<T>, Action<Exception>)
    ObservableExtensions.Subscribe<T>(IObservable<T>, Action<T>, Action)
    ObservableExtensions.Subscribe<T>(IObservable<T>, Action<T>, Action<Exception>, Action)
    ObservableExtensions.Subscribe<T>(IObservable<T>, IObserver<T>, CancellationToken)
    ObservableExtensions.Subscribe<T>(IObservable<T>, CancellationToken)
    ObservableExtensions.Subscribe<T>(IObservable<T>, Action<T>, CancellationToken)
    ObservableExtensions.Subscribe<T>(IObservable<T>, Action<T>, Action<Exception>, CancellationToken)
    ObservableExtensions.Subscribe<T>(IObservable<T>, Action<T>, Action, CancellationToken)
    ObservableExtensions.Subscribe<T>(IObservable<T>, Action<T>, Action<Exception>, Action, CancellationToken)
    ObservableExtensions.SubscribeSafe<T>(IObservable<T>, IObserver<T>)
    • Improve this Doc
    • View Source
    In This Article
    Back to top Generated by DocFX