# Observable Methods

Include Protected Members
Include Inherited Members

The Observable type exposes the following members.

## Methods

Name Description
Aggregate<TSource>(IObservable<TSource>, Func<TSource, TSource, TSource>) Applies an accumulator function over an observable sequence.
Aggregate<TSource, TAccumulate>(IObservable<TSource>, TAccumulate, Func<TAccumulate, TSource, TAccumulate>) Applies an accumulator function over an observable sequence with the specified seed value.
All<TSource> Determines whether all elements of an observable sequence satisfies a condition.
Amb<TSource>(IEnumerable<IObservable<TSource>>) Propagates the observable sequence that reacts first with a specified sources.
Amb<TSource>(IObservable<TSource>[]) Propagates the observable sequence that reacts first with a specified sources.
Amb<TSource>(IObservable<TSource>, IObservable<TSource>) Propagates the observable sequence that reacts first with the specified first and second sequence.
And<TLeft, TRight> Matches when both observable sequences have an available value.
Any<TSource>(IObservable<TSource>) Determines whether an observable sequence contains any elements.
Any<TSource>(IObservable<TSource>, Func<TSource, Boolean>) Determines whether all elements of an observable sequence satisfies a condition.
AsObservable<TSource> Hides the identity of an observable sequence.
Average(IObservable<Decimal>) Computes the average of an observable sequence of Decimal values.
Average(IObservable<Double>) Computes the average of an observable sequence of Double values.
Average(IObservable<Int32>) Computes the average of an observable sequence of Int32 values.
Average(IObservable<Int64>) Computes the average of an observable sequence of Int64 values.
Average(IObservable<Nullable<Decimal>>) Computes the average of an observable sequence of nullable Decimal values.
Average(IObservable<Nullable<Double>>) Computes the average of an observable sequence of nullable Double values.
Average(IObservable<Nullable<Int32>>) Computes the average of an observable sequence of nullable Int32 values.
Average(IObservable<Nullable<Int64>>) Computes the average of an observable sequence of nullable Int64 values.
Average(IObservable<Nullable<Single>>) Computes the average of an observable sequence of nullable Float values.
Average(IObservable<Single>) Computes the average of an observable sequence of Float values.
Buffer<TSource>(IObservable<TSource>, Int32) Indicates each element of an observable sequence into consecutive non-overlapping buffers which are produced based on element count information.
Buffer<TSource>(IObservable<TSource>, TimeSpan) Indicates each element of an observable sequence into consecutive non-overlapping buffers which are produced based on timing information.
Buffer<TSource>(IObservable<TSource>, Int32, Int32) Indicates each element of an observable sequence into zero or more buffers which are produced based on element count information.
Buffer<TSource>(IObservable<TSource>, TimeSpan, Int32) Indicates each element of an observable sequence into a buffer that’s sent out when either it’s full or a given amount of time has elapsed.
Buffer<TSource>(IObservable<TSource>, TimeSpan, IScheduler) Indicates each element of an observable sequence into consecutive non-overlapping buffers which are produced based on timing information.
Buffer<TSource>(IObservable<TSource>, TimeSpan, TimeSpan) Indicates each element of an observable sequence into zero or more buffers which are produced based on timing information.
Buffer<TSource>(IObservable<TSource>, TimeSpan, Int32, IScheduler) Indicates each element of an observable sequence into a buffer that’s sent out when either it’s full or a given amount of time has elapsed.
Buffer<TSource>(IObservable<TSource>, TimeSpan, TimeSpan, IScheduler) Indicates each element of an observable sequence into zero or more buffers which are produced based on timing information.
Buffer<TSource, TBufferClosing>(IObservable<TSource>, Func<IObservable<TBufferClosing>>) Indicates each element of an observable sequence into consecutive non-overlapping buffers.
Buffer<TSource, TBufferOpening, TBufferClosing>(IObservable<TSource>, IObservable<TBufferOpening>, Func<TBufferOpening, IObservable<TBufferClosing>>) Indicates each element of a queryable observable sequence into consecutive non-overlapping buffers.
Cast<TResult> Converts the elements of an observable sequence to the specified type.
Catch<TSource>(IEnumerable<IObservable<TSource>>) Continues an observable sequence that is terminated by an exception with the next observable sequence.
Catch<TSource>(IObservable<TSource>[]) Continues an observable sequence that is terminated by an exception with the next observable sequence.
Catch<TSource>(IObservable<TSource>, IObservable<TSource>) Continues an observable sequence that is terminated by an exception with the next observable sequence.
Catch<TSource, TException>(IObservable<TSource>, Func<TException, IObservable<TSource>>) Continues an observable sequence that is terminated by an exception of the specified type with the observable sequence produced by the handler.
CombineLatest<TFirst, TSecond, TResult> Merges two observable sequences into one observable sequence by using the selector function whenever one of the observable sequences produces an element.
Concat<TSource>(IEnumerable<IObservable<TSource>>) Concatenates an enumerable sequence of observable sequences.
Concat<TSource>(IObservable<IObservable<TSource>>) Concatenates an observable sequence of observable sequences.
Concat<TSource>(IObservable<TSource>[]) Concatenates all the observable sequences.
Concat<TSource>(IObservable<TSource>, IObservable<TSource>) Concatenates two observable sequences.
Contains<TSource>(IObservable<TSource>, TSource) Determines whether an observable sequence contains a specified element by using the default equality comparer.
Contains<TSource>(IObservable<TSource>, TSource, IEqualityComparer<TSource>) Determines whether an observable sequence contains a specified element by using a specified System.Collections.Generic.IEqualityComparer&lt;T&gt;.
Count<TSource> Returns a Int32 that represents the total number of elements in an observable sequence.
Create<TSource>(Func<IObserver<TSource>, Action>) Creates an observable sequence from a specified subscribe method implementation with a specified subscribe.
Create<TSource>(Func<IObserver<TSource>, IDisposable>) Creates an observable sequence from a subscribe method implementation.
DefaultIfEmpty<TSource>(IObservable<TSource>) Returns the elements of the specified sequence or the type parameter's default value in a singleton sequence if the sequence is empty.
DefaultIfEmpty<TSource>(IObservable<TSource>, TSource) Returns the elements of the specified sequence or the type parameter's default value in a singleton sequence if the sequence is empty.
Defer<TValue> Returns an observable sequence that invokes the observable factory whenever a new observer subscribes.
Delay<TSource>(IObservable<TSource>, DateTimeOffset) Indicates the observable sequence by due time with the specified source and dueTime.
Delay<TSource>(IObservable<TSource>, TimeSpan) Indicates the observable sequence by due time with the specified source and dueTime.
Delay<TSource>(IObservable<TSource>, DateTimeOffset, IScheduler) Indicates the observable sequence by due time with the specified source, dueTime and scheduler.
Delay<TSource>(IObservable<TSource>, TimeSpan, IScheduler) Indicates the observable sequence by due time with the specified source, dueTime and scheduler.
Dematerialize<TSource> Dematerializes the explicit notification values of an observable sequence as implicit notifications.
Distinct<TSource>(IObservable<TSource>) Returns an observable sequence that contains only distinct elements with a specified source.
Distinct<TSource>(IObservable<TSource>, IEqualityComparer<TSource>) Returns an observable sequence that contains only distinct elements according to the comparer.
Distinct<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>) Returns an observable sequence that contains only distinct elements according to the keySelector.
Distinct<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>, IEqualityComparer<TKey>) Returns an observable sequence that contains only distinct elements according to the keySelector.
DistinctUntilChanged<TSource>(IObservable<TSource>) Returns an observable sequence that contains only distinct contiguous elements with a specified source.
DistinctUntilChanged<TSource>(IObservable<TSource>, IEqualityComparer<TSource>) Returns an observable sequence that contains only distinct contiguous elements according to the comparer.
DistinctUntilChanged<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>) Returns an observable sequence that contains only distinct contiguous elements according to the keySelector.
DistinctUntilChanged<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>, IEqualityComparer<TKey>) Returns an observable sequence that contains only distinct contiguous elements according to the keySelector and the comparer.
Do<TSource>(IObservable<TSource>, Action<TSource>) Invokes an action for each element in the observable sequence.
Do<TSource>(IObservable<TSource>, IObserver<TSource>) Invokes an action for each element in the observable sequence and invokes an action upon exceptional termination of the observable sequence.
Do<TSource>(IObservable<TSource>, Action<TSource>, Action) Invokes an action for each element in the observable sequence and invokes an action upon graceful termination of the observable sequence.
Do<TSource>(IObservable<TSource>, Action<TSource>, Action<Exception>) Invokes an action for each element in the observable sequence and invokes an action upon exceptional termination of the observable sequence.
Do<TSource>(IObservable<TSource>, Action<TSource>, Action<Exception>, Action) Invokes an action for each element in the observable sequence, and invokes an action upon graceful or exceptional termination of the observable sequence.
ElementAt<TSource> Returns the element at a specified index in a sequence.
ElementAtOrDefault<TSource> Returns the element at a specified index in a sequence or a default value if the index is out of range.
Empty<TResult>() Returns an empty observable sequence.
Empty<TResult>(IScheduler) Returns an empty observable sequence with the specified scheduler.
Finally<TSource> Invokes a specified action after source observable sequence terminates normally or by an exception.
First<TSource>(IObservable<TSource>) Returns the first element of an observable sequence with a specified source.
First<TSource>(IObservable<TSource>, Func<TSource, Boolean>) Returns the first element of an observable sequence that matches the predicate.
FirstOrDefault<TSource>(IObservable<TSource>) Returns the first element of an observable sequence, or a default value if no value is found.
FirstOrDefault<TSource>(IObservable<TSource>, Func<TSource, Boolean>) Returns the first element of an observable sequence that matches the predicate, or a default value if no value is found.
ForEach<TSource> Invokes an action for each element in the observable sequence, and blocks until the sequence is terminated.
FromAsyncPattern(Func<AsyncCallback, Object, IAsyncResult>, Action<IAsyncResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<TResult>(Func<AsyncCallback, Object, IAsyncResult>, Func<IAsyncResult, TResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1>(Func<T1, AsyncCallback, Object, IAsyncResult>, Action<IAsyncResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, AsyncCallback, Object, IAsyncResult>, Func<IAsyncResult, TResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, AsyncCallback, Object, IAsyncResult>, Action<IAsyncResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, AsyncCallback, Object, IAsyncResult>, Func<IAsyncResult, TResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, AsyncCallback, Object, IAsyncResult>, Action<IAsyncResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, AsyncCallback, Object, IAsyncResult>, Func<IAsyncResult, TResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, AsyncCallback, Object, IAsyncResult>, Action<IAsyncResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, AsyncCallback, Object, IAsyncResult>, Func<IAsyncResult, TResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, AsyncCallback, Object, IAsyncResult>, Action<IAsyncResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, AsyncCallback, Object, IAsyncResult>, Func<IAsyncResult, TResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, AsyncCallback, Object, IAsyncResult>, Action<IAsyncResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, AsyncCallback, Object, IAsyncResult>, Func<IAsyncResult, TResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, TResult>(Func<T1, AsyncCallback, Object, IAsyncResult>, Func<IAsyncResult, TResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, T2>(Func<T1, T2, AsyncCallback, Object, IAsyncResult>, Action<IAsyncResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, T2, TResult>(Func<T1, T2, AsyncCallback, Object, IAsyncResult>, Func<IAsyncResult, TResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, T2, T3>(Func<T1, T2, T3, AsyncCallback, Object, IAsyncResult>, Action<IAsyncResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, T2, T3, TResult>(Func<T1, T2, T3, AsyncCallback, Object, IAsyncResult>, Func<IAsyncResult, TResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, T2, T3, T4>(Func<T1, T2, T3, T4, AsyncCallback, Object, IAsyncResult>, Action<IAsyncResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, T2, T3, T4, TResult>(Func<T1, T2, T3, T4, AsyncCallback, Object, IAsyncResult>, Func<IAsyncResult, TResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, T2, T3, T4, T5>(Func<T1, T2, T3, T4, T5, AsyncCallback, Object, IAsyncResult>, Action<IAsyncResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, T2, T3, T4, T5, TResult>(Func<T1, T2, T3, T4, T5, AsyncCallback, Object, IAsyncResult>, Func<IAsyncResult, TResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, T2, T3, T4, T5, T6>(Func<T1, T2, T3, T4, T5, T6, AsyncCallback, Object, IAsyncResult>, Action<IAsyncResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7>(Func<T1, T2, T3, T4, T5, T6, T7, AsyncCallback, Object, IAsyncResult>, Action<IAsyncResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, T2, T3, T4, T5, T6, TResult>(Func<T1, T2, T3, T4, T5, T6, AsyncCallback, Object, IAsyncResult>, Func<IAsyncResult, TResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, AsyncCallback, Object, IAsyncResult>, Func<IAsyncResult, TResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8>(Func<T1, T2, T3, T4, T5, T6, T7, T8, AsyncCallback, Object, IAsyncResult>, Action<IAsyncResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, T8, AsyncCallback, Object, IAsyncResult>, Func<IAsyncResult, TResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, AsyncCallback, Object, IAsyncResult>, Action<IAsyncResult>) Converts a Begin/End invoke function pair into an asynchronous function.
FromEvent(Action<Action>, Action<Action>) Converts a .NET event to an observable sequence.
FromEvent<TEventArgs>(Action<Action<TEventArgs>>, Action<Action<TEventArgs>>) Converts a .NET event to an observable sequence.
FromEvent<TDelegate, TEventArgs>(Action<TDelegate>, Action<TDelegate>) Converts a .NET event to an observable sequence.
FromEvent<TDelegate, TEventArgs>(Func<Action<TEventArgs>, TDelegate>, Action<TDelegate>, Action<TDelegate>) Converts a .NET event to an observable sequence.
FromEventPattern(Action<EventHandler>, Action<EventHandler>) Converts a .NET event, conforming to the standard .NET event pattern, to an observable sequence with a specified add handler and remove handler.
FromEventPattern(Object, String) Converts a .NET event, conforming to the standard .NET event pattern, to an observable sequence, using reflection to find an instance event.
FromEventPattern(Type, String) Converts a .NET event, conforming to the standard .NET event pattern, to an observable sequence, using reflection to find a static event.
FromEventPattern<TEventArgs>(Action<EventHandler<TEventArgs>>, Action<EventHandler<TEventArgs>>) Converts a .NET event, conforming to the standard .NET event pattern, to an observable sequence with the specified add handler and remove handler.
FromEventPattern<TEventArgs>(Object, String) Converts a .NET event, conforming to the standard .NET event pattern, to an observable sequence, using reflection to find an instance event.
FromEventPattern<TEventArgs>(Type, String) Converts a .NET event, conforming to the standard .NET event pattern, to an observable sequence, using reflection to find a static event.
FromEventPattern<TDelegate, TEventArgs>(Action<TDelegate>, Action<TDelegate>) Converts a .NET event, conforming to the standard .NET event pattern, to an observable sequence with the specified add handler and remove handler.
FromEventPattern<TDelegate, TEventArgs>(Func<EventHandler<TEventArgs>, TDelegate>, Action<TDelegate>, Action<TDelegate>) Converts a .NET event, conforming to the standard .NET event pattern, to an observable sequence with the specified conversion, add handler and remove handler.
Generate<TState, TResult>(TState, Func<TState, Boolean>, Func<TState, TState>, Func<TState, TResult>) Generates an observable sequence by iterating a state from an initial state until the condition fails.
Generate<TState, TResult>(TState, Func<TState, Boolean>, Func<TState, TState>, Func<TState, TResult>, Func<TState, DateTimeOffset>) Generates an observable sequence by iterating a state from an initial state until the condition fails.
Generate<TState, TResult>(TState, Func<TState, Boolean>, Func<TState, TState>, Func<TState, TResult>, Func<TState, TimeSpan>) Generates an observable sequence by iterating a state from an initial state until the condition fails.
Generate<TState, TResult>(TState, Func<TState, Boolean>, Func<TState, TState>, Func<TState, TResult>, IScheduler) Generates an observable sequence by iterating a state from an initial state until the condition fails.
Generate<TState, TResult>(TState, Func<TState, Boolean>, Func<TState, TState>, Func<TState, TResult>, Func<TState, DateTimeOffset>, IScheduler) Generates an observable sequence by iterating a state from an initial state until the condition fails.
Generate<TState, TResult>(TState, Func<TState, Boolean>, Func<TState, TState>, Func<TState, TResult>, Func<TState, TimeSpan>, IScheduler) Generates an observable sequence by iterating a state from an initial state until the condition fails.
GetEnumerator<TSource> Returns an enumerator that enumerates all values of the observable sequence.
GroupBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>) Groups the elements of an observable sequence according to a specified key selector function.
GroupBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>, IEqualityComparer<TKey>) Groups the elements of an observable sequence according to a specified key selector function and comparer.
GroupBy<TSource, TKey, TElement>(IObservable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>) Groups the elements of an observable sequence and selects the resulting elements by using a specified function.
GroupBy<TSource, TKey, TElement>(IObservable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>, IEqualityComparer<TKey>) Groups the elements of an observable sequence according to a specified key selector function and comparer and selects the resulting elements by using a specified function.
GroupByUntil<TSource, TKey, TDuration>(IObservable<TSource>, Func<TSource, TKey>, Func<IGroupedObservable<TKey, TSource>, IObservable<TDuration>>) Groups the elements of an observable sequence according to a specified key selector function.
GroupByUntil<TSource, TKey, TDuration>(IObservable<TSource>, Func<TSource, TKey>, Func<IGroupedObservable<TKey, TSource>, IObservable<TDuration>>, IEqualityComparer<TKey>) Groups the elements of an observable sequence according to a specified key selector function and comparer.
GroupByUntil<TSource, TKey, TElement, TDuration>(IObservable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>, Func<IGroupedObservable<TKey, TElement>, IObservable<TDuration>>) Groups the elements of an observable sequence according to a specified key selector function and selects the resulting elements by using a specified function.
GroupByUntil<TSource, TKey, TElement, TDuration>(IObservable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>, Func<IGroupedObservable<TKey, TElement>, IObservable<TDuration>>, IEqualityComparer<TKey>) Groups the elements of an observable sequence according to a specified key selector function and comparer and selects the resulting elements by using a specified function.
GroupJoin<TLeft, TRight, TLeftDuration, TRightDuration, TResult> Correlates the elements of two sequences based on overlapping durations, and groups the results.
IgnoreElements<TSource> Ignores all values in an observable sequence leaving only the termination messages.
Interval(TimeSpan) Returns an observable sequence that produces a value after each period.
Interval(TimeSpan, IScheduler) Returns an observable sequence that produces a value after each period.
Join<TLeft, TRight, TLeftDuration, TRightDuration, TResult> Correlates the elements of two sequences based on overlapping durations.
Last<TSource>(IObservable<TSource>) Returns the last element of an observable sequence with a specified source.
Last<TSource>(IObservable<TSource>, Func<TSource, Boolean>) Returns the last element of an observable sequence that matches the predicate.
LastOrDefault<TSource>(IObservable<TSource>) Returns last element in the observable sequence, or a default value if no value is found.
LastOrDefault<TSource>(IObservable<TSource>, Func<TSource, Boolean>) Returns the last element of an observable sequence that matches the predicate, or a default value if no value is found.
Latest<TSource> Samples the most recent value in an observable sequence.
LongCount<TSource> Returns a Int64 that represents the total number of elements in an observable sequence.
Materialize<TSource> Materializes the implicit notifications of an observable sequence as explicit notification values.
Max(IObservable<Decimal>) Returns the maximum value in an observable sequence of Decimal values.
Max(IObservable<Double>) Returns the maximum value in an observable sequence of Double values.
Max(IObservable<Int32>) Returns the maximum value in an observable sequence of Int32 values.
Max(IObservable<Int64>) Returns the maximum value in an observable sequence of Int64 values.
Max(IObservable<Nullable<Decimal>>) Returns the maximum value in an observable sequence of nullable Decimal values.
Max(IObservable<Nullable<Double>>) Returns the maximum value in an observable sequence of nullable Double values.
Max(IObservable<Nullable<Int32>>) Returns the maximum value in an observable sequence of nullable Int32 values.
Max(IObservable<Nullable<Int64>>) Returns the maximum value in an observable sequence of nullable Int64 values.
Max(IObservable<Nullable<Single>>) Returns the maximum value in an observable sequence of nullable Float values.
Max(IObservable<Single>) Returns the maximum value in an observable sequence of Float values.
Max<TSource>(IObservable<TSource>) Returns the maximum element in an observable sequence.
Max<TSource>(IObservable<TSource>, IComparer<TSource>) Returns the maximum value in an observable sequence according to the specified comparer.
MaxBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>) Returns the elements in an observable sequence with the maximum key value.
MaxBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>, IComparer<TKey>) Returns the elements in an observable sequence with the maximum key value.
Merge<TSource>(IEnumerable<IObservable<TSource>>) Merges an enumerable sequence of observable sequences into a single observable sequence.
Merge<TSource>(IObservable<IObservable<TSource>>) Merges an observable sequence of observable sequences into an observable sequence.
Merge<TSource>(IObservable<TSource>[]) Merges all the observable sequences into a single observable sequence.
Merge<TSource>(IEnumerable<IObservable<TSource>>, Int32) Merges an enumerable sequence of observable sequences into an observable sequence, limiting the number of concurrent subscriptions to inner sequences.
Merge<TSource>(IEnumerable<IObservable<TSource>>, IScheduler) Merges an enumerable sequence of observable sequences into a single observable sequence.
Merge<TSource>(IObservable<IObservable<TSource>>, Int32) Merges an enumerable sequence of observable sequences into an observable sequence, limiting the number of concurrent subscriptions to inner sequences.
Merge<TSource>(IObservable<TSource>, IObservable<TSource>) Merges an observable sequence of observable sequences into an observable sequence.
Merge<TSource>(IScheduler, IObservable<TSource>[]) Merges all the observable sequences into a single observable sequence.
Merge<TSource>(IEnumerable<IObservable<TSource>>, Int32, IScheduler) Merges an enumerable sequence of observable sequences into an observable sequence, limiting the number of concurrent subscriptions to inner sequences.
Merge<TSource>(IObservable<TSource>, IObservable<TSource>, IScheduler) Merges two observable sequences into a single observable sequence.
Min(IObservable<Decimal>) Returns the minimum value in an observable sequence of Decimal values.
Min(IObservable<Double>) Returns the minimum value in an observable sequence of Double values.
Min(IObservable<Int32>) Returns the minimum value in an observable sequence of Int32 values.
Min(IObservable<Int64>) Returns the minimum value in an observable sequence of Int64 values.
Min(IObservable<Nullable<Decimal>>) Returns the minimum value in an observable sequence of nullable Decimal values.
Min(IObservable<Nullable<Double>>) Returns the minimum value in an observable sequence of nullable Double values.
Min(IObservable<Nullable<Int32>>) Returns the minimum value in an observable sequence of nullable Int32 values.
Min(IObservable<Nullable<Int64>>) Returns the minimum value in an observable sequence of nullable Int64 values.
Min(IObservable<Nullable<Single>>) Returns the minimum value in an observable sequence of nullable Float values.
Min(IObservable<Single>) Returns the minimum value in an observable sequence of Float values.
Min<TSource>(IObservable<TSource>) Returns the minimum element in an observable sequence.
Min<TSource>(IObservable<TSource>, IComparer<TSource>) Returns the minimum value in an observable sequence according to the specified comparer.
MinBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>) Returns the elements in an observable sequence with the minimum key value.
MinBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>, IComparer<TKey>) Returns the elements in an observable sequence with the minimum key value according to the specified comparer.
MostRecent<TSource> Samples the most recent value in an observable sequence.
Multicast<TSource, TResult>(IObservable<TSource>, ISubject<TSource, TResult>) Returns a connectable observable sequence that upon connection causes the source sequence to push results into the specified subject.
Multicast<TSource, TIntermediate, TResult>(IObservable<TSource>, Func<ISubject<TSource, TIntermediate>>, Func<IObservable<TIntermediate>, IObservable<TResult>>) Returns an observable sequence that contains the elements of a sequence produced by multicasting the source sequence within a selector function.
Never<TResult> Returns a non-terminating observable sequence.
Next<TSource> Samples the next value (blocking without buffering) from in an observable sequence.
ObserveOn<TSource>(IObservable<TSource>, IScheduler) Asynchronously notify observers on the specified scheduler.
ObserveOn<TSource>(IObservable<TSource>, SynchronizationContext) Asynchronously notify observers on the specified synchronization context.
OfType<TResult> Filters the elements of an observable sequence based on the specified type.
OnErrorResumeNext<TSource>(IEnumerable<IObservable<TSource>>) Continues an observable sequence that is terminated normally or by an exception with the next observable sequence.
OnErrorResumeNext<TSource>(IObservable<TSource>[]) Continues an observable sequence that is terminated normally or by an exception with the next observable sequence.
OnErrorResumeNext<TSource>(IObservable<TSource>, IObservable<TSource>) Continues an observable sequence that is terminated normally or by an exception with the next observable sequence.
Publish<TSource>(IObservable<TSource>) Returns a connectable observable sequence that shares a single subscription to the underlying sequence.
Publish<TSource>(IObservable<TSource>, TSource) Returns a connectable observable sequence that shares a single subscription to the underlying sequence and starts with initialValue.
Publish<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>) Returns an observable sequence that is the result of invoking the selector on a connectable observable sequence that shares a single subscription to the underlying sequence.
Publish<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, TSource) Returns a connectable observable sequence that shares a single subscription to the underlying sequence and starts with initialValue.
PublishLast<TSource>(IObservable<TSource>) Returns a connectable observable sequence that shares a single subscription to the underlying sequence containing only the last notification.
PublishLast<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>) Returns an observable sequence that is the result of invoking the selector on a connectable observable sequence that shares a single subscription to the underlying sequence containing only the last notification.
Range(Int32, Int32) Generates an observable sequence of integral numbers within a specified range.
Range(Int32, Int32, IScheduler) Generates an observable sequence of integral numbers within a specified range.
RefCount<TSource> Returns an observable sequence that stays connected to the source as long as there is at least one subscription to the observable sequence.
Repeat<TSource>(IObservable<TSource>) Repeats the observable sequence indefinitely.
Repeat<TResult>(TResult) Generates an observable sequence that repeats the given element infinitely.
Repeat<TSource>(IObservable<TSource>, Int32) Repeats the observable sequence indefinitely.
Repeat<TResult>(TResult, Int32) Generates an observable sequence that repeats the given element the specified number of times.
Repeat<TResult>(TResult, IScheduler) Generates an observable sequence that repeats the given element infinitely.
Repeat<TResult>(TResult, Int32, IScheduler) Generates an observable sequence that repeats the given element of the specified number of times.
Replay<TSource>(IObservable<TSource>) Returns a connectable observable sequence that shares a single subscription to the underlying sequence replaying all notifications.
Replay<TSource>(IObservable<TSource>, Int32) Returns a connectable observable sequence that shares a single subscription to the underlying sequence replaying bufferSize notifications.
Replay<TSource>(IObservable<TSource>, IScheduler) Returns a connectable observable sequence that shares a single subscription to the underlying sequence replaying all notifications.
Replay<TSource>(IObservable<TSource>, TimeSpan) Returns a connectable observable sequence that shares a single subscription to the underlying sequence replaying all notifications within window.
Replay<TSource>(IObservable<TSource>, Int32, IScheduler) Returns a connectable observable sequence that shares a single subscription to the underlying sequence replaying bufferSize notifications.
Replay<TSource>(IObservable<TSource>, Int32, TimeSpan) Returns a connectable observable sequence that shares a single subscription to the underlying sequence replaying bufferSize notifications within window.
Replay<TSource>(IObservable<TSource>, TimeSpan, IScheduler) Returns a connectable observable sequence that shares a single subscription to the underlying sequence replaying all notifications within window.
Replay<TSource>(IObservable<TSource>, Int32, TimeSpan, IScheduler) Returns a connectable observable sequence that shares a single subscription to the underlying sequence replaying bufferSize notifications within window.
Replay<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>) Returns an observable sequence that is the result of invoking the selector on a connectable observable sequence that shares a single subscription to the underlying sequence and starts with initial value.
Replay<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, Int32) Returns an observable sequence that is the result of invoking the selector on a connectable observable sequence that shares a single subscription to the underlying sequence replaying bufferSize notifications.
Replay<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, IScheduler) Returns an observable sequence that is the result of invoking the selector on a connectable observable sequence that shares a single subscription to the underlying sequence replaying all notifications.
Replay<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, TimeSpan) Returns an observable sequence that is the result of invoking the selector on a connectable observable sequence that shares a single subscription to the underlying sequence replaying all notifications within window.
Replay<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, Int32, IScheduler) Returns an observable sequence that is the result of invoking the selector on a connectable observable sequence that shares a single subscription to the underlying sequence replaying bufferSize notifications.
Replay<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, Int32, TimeSpan) Returns an observable sequence that is the result of invoking the selector on a connectable observable sequence that shares a single subscription to the underlying sequence replaying bufferSize notifications within window.
Replay<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, TimeSpan, IScheduler) Returns an observable sequence that is the result of invoking the selector on a connectable observable sequence that shares a single subscription to the underlying sequence replaying all notifications within window.
Replay<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, Int32, TimeSpan, IScheduler) Returns an observable sequence that is the result of invoking the selector on a connectable observable sequence that shares a single subscription to the underlying sequence replaying bufferSize notifications within window.
Retry<TSource>(IObservable<TSource>) Repeats the source observable sequence until it successfully terminates.
Retry<TSource>(IObservable<TSource>, Int32) Repeats the source observable sequence until it successfully terminates.
Return<TResult>(TResult) Returns an observable sequence that contains a single element with a specified value.
Return<TResult>(TResult, IScheduler) Returns an observable sequence that contains a single value with a specified value and scheduler.
Sample<TSource>(IObservable<TSource>, TimeSpan) Samples the observable sequence at each interval.
Sample<TSource>(IObservable<TSource>, TimeSpan, IScheduler) Samples the observable sequence at each interval with the specified source, interval and scheduler.
Sample<TSource, TSample>(IObservable<TSource>, IObservable<TSample>) Samples the observable sequence at sampling ticks with the specified source and sampler.
Scan<TSource>(IObservable<TSource>, Func<TSource, TSource, TSource>) Applies an accumulator function over an observable sequence and returns each intermediate result with the specified source and accumulator.
Scan<TSource, TAccumulate>(IObservable<TSource>, TAccumulate, Func<TAccumulate, TSource, TAccumulate>) Applies an accumulator function over an observable sequence and returns each intermediate result with the specified source, seed and accumulator.
Select<TSource, TResult>(IObservable<TSource>, Func<TSource, TResult>) Projects each element of an observable sequence into a new form with the specified source and selector.
Select<TSource, TResult>(IObservable<TSource>, Func<TSource, Int32, TResult>) Projects each element of an observable sequence into a new form by incorporating the element’s index with the specified source and selector.
SelectMany<TSource, TResult>(IObservable<TSource>, Func<TSource, IEnumerable<TResult>>) Projects each element of an observable sequence to an observable sequence and flattens the resulting observable sequences into one observable sequence.
SelectMany<TSource, TResult>(IObservable<TSource>, Func<TSource, IObservable<TResult>>) Projects each element of an observable sequence to an observable sequence and flattens the resulting observable sequences into one observable sequence.
SelectMany<TSource, TOther>(IObservable<TSource>, IObservable<TOther>) Projects each element of an observable sequence to an observable sequence and flattens the resulting observable sequences into one observable sequence.
SelectMany<TSource, TResult>(IObservable<TSource>, Func<TSource, IObservable<TResult>>, Func<Exception, IObservable<TResult>>, Func<IObservable<TResult>>) Projects each element of an observable sequence to an observable sequence and flattens the resulting observable sequences into one observable sequence.
SelectMany<TSource, TCollection, TResult>(IObservable<TSource>, Func<TSource, IEnumerable<TCollection>>, Func<TSource, TCollection, TResult>) Projects each element of an observable sequence to an observable sequence and flattens the resulting observable sequences into one observable sequence.
SelectMany<TSource, TCollection, TResult>(IObservable<TSource>, Func<TSource, IObservable<TCollection>>, Func<TSource, TCollection, TResult>) Projects each element of an observable sequence to an observable sequence and flattens the resulting observable sequences into one observable sequence.
SequenceEqual<TSource>(IObservable<TSource>, IObservable<TSource>) Determines whether two sequences are equal by comparing the elements pairwise.
SequenceEqual<TSource>(IObservable<TSource>, IObservable<TSource>, IEqualityComparer<TSource>) Determines whether two sequences are equal by comparing the elements pairwise using a specified equality comparer.
Single<TSource>(IObservable<TSource>) Returns the only element of an observable sequence and throws an exception if there is not exactly one element in the observable sequence.
Single<TSource>(IObservable<TSource>, Func<TSource, Boolean>) Returns the only element of an observable sequence that matches the predicate and throws an exception if there is not exactly one element in the observable sequence.
SingleOrDefault<TSource>(IObservable<TSource>) Returns the only element of an observable sequence, or a default value if the observable sequence is empty.
SingleOrDefault<TSource>(IObservable<TSource>, Func<TSource, Boolean>) Returns the only element of an observable sequence that matches the predicate, or a default value if no value is found.
Skip<TSource> Bypasses a specified number of values in an observable sequence and then returns the remaining values.
SkipLast<TSource> Bypasses a specified number of elements at the end of an observable sequence.
SkipUntil<TSource, TOther> Returns the values from the source observable sequence only after the other observable sequence produces a value.
SkipWhile<TSource>(IObservable<TSource>, Func<TSource, Boolean>) Bypasses values in an observable sequence as long as a specified condition is true and then returns the remaining values.
SkipWhile<TSource>(IObservable<TSource>, Func<TSource, Int32, Boolean>) Bypasses values in an observable sequence as long as a specified condition is true and then returns the remaining values.
Start(Action) Invokes the action asynchronously.
Start(Action, IScheduler) Invokes the action asynchronously.
Start<TSource>(Func<TSource>) Invokes the function asynchronously.
Start<TSource>(Func<TSource>, IScheduler) Invokes the function asynchronously.
StartWith<TSource>(IObservable<TSource>, TSource[]) Prepends a sequence of values to an observable sequence with the specified source and values.
StartWith<TSource>(IObservable<TSource>, IScheduler, TSource[]) Prepends a sequence of values to an observable sequence with the specified source, scheduler and values.
Subscribe<TSource>(IEnumerable<TSource>, IObserver<TSource>) Subscribes an observer to an enumerable sequence with the specified source and observer.
Subscribe<TSource>(IEnumerable<TSource>, IObserver<TSource>, IScheduler) Subscribes an observer to an enumerable sequence with the specified source and observer.
SubscribeOn<TSource>(IObservable<TSource>, IScheduler) Asynchronously subscribes and unsubscribes observers on the specified scheduler.
SubscribeOn<TSource>(IObservable<TSource>, SynchronizationContext) Asynchronously subscribes and unsubscribes observers on the specified synchronization context.
Sum(IObservable<Decimal>) Computes the sum of a sequence of Decimal values.
Sum(IObservable<Double>) Computes the sum of a sequence of Double values.
Sum(IObservable<Int32>) Computes the sum of a sequence of Int32 values.
Sum(IObservable<Int64>) Computes the sum of a sequence of Int64 values.
Sum(IObservable<Nullable<Decimal>>) Computes the sum of a sequence of nullable Decimal values.
Sum(IObservable<Nullable<Double>>) Computes the sum of a sequence of nullable Double values.
Sum(IObservable<Nullable<Int32>>) Computes the sum of a sequence of nullable Int32 values.
Sum(IObservable<Nullable<Int64>>) Computes the sum of a sequence of nullable Int64 values.
Sum(IObservable<Nullable<Single>>) Computes the sum of a sequence of nullable Float values.
Sum(IObservable<Single>) Computes the sum of a sequence of Float values.
Switch<TSource> Transforms an observable sequence of observable sequences into an observable sequence producing values only from the most recent observable sequence.
Synchronize<TSource>(IObservable<TSource>) Synchronizes the observable sequence.
Synchronize<TSource>(IObservable<TSource>, Object) Synchronizes the observable sequence.
Take<TSource> Returns a specified number of contiguous values from the start of an observable sequence.
TakeLast<TSource> Returns a specified number of contiguous elements from the end of an observable sequence.
TakeUntil<TSource, TOther> Returns the values from the source observable sequence until the other observable sequence produces a value.
TakeWhile<TSource>(IObservable<TSource>, Func<TSource, Boolean>) Returns values from an observable sequence as long as a specified condition is true, and then skips the remaining values.
TakeWhile<TSource>(IObservable<TSource>, Func<TSource, Int32, Boolean>) Returns values from an observable sequence as long as a specified condition is true, and then skips the remaining values.
Then<TSource, TResult> Matches when the observable sequence has an available value and projects the value.
Throttle<TSource>(IObservable<TSource>, TimeSpan) Ignores the values from an observable sequence which are followed by another value before due time with the specified source and dueTime.
Throttle<TSource>(IObservable<TSource>, TimeSpan, IScheduler) Ignores the values from an observable sequence which are followed by another value before due time with the specified source, dueTime and scheduler.
Throw<TResult>(Exception) Returns an observable sequence that terminates with an exception.
Throw<TResult>(Exception, IScheduler) Returns an observable sequence that terminates with an exception with the specified scheduler.
TimeInterval<TSource>(IObservable<TSource>) Records the time interval between consecutive values in an observable sequence with the specified source.
TimeInterval<TSource>(IObservable<TSource>, IScheduler) Records the time interval between consecutive values in an observable sequence with the specified source and scheduler.
Timeout<TSource>(IObservable<TSource>, DateTimeOffset) Returns either the observable sequence or a TimeoutException if dueTime elapses.
Timeout<TSource>(IObservable<TSource>, TimeSpan) Returns either the observable sequence or an TimeoutException if dueTime elapses.
Timeout<TSource>(IObservable<TSource>, DateTimeOffset, IObservable<TSource>) Returns either the observable sequence or an TimeoutException if dueTime elapses.
Timeout<TSource>(IObservable<TSource>, DateTimeOffset, IScheduler) Returns either the observable sequence or an TimeoutException if dueTime elapses.
Timeout<TSource>(IObservable<TSource>, TimeSpan, IObservable<TSource>) Returns the source observable sequence or the other observable sequence if dueTime elapses.
Timeout<TSource>(IObservable<TSource>, TimeSpan, IScheduler) Returns either the observable sequence or an TimeoutException if dueTime elapses.
Timeout<TSource>(IObservable<TSource>, DateTimeOffset, IObservable<TSource>, IScheduler) Returns the source observable sequence or the other observable sequence if dueTime elapses.
Timeout<TSource>(IObservable<TSource>, TimeSpan, IObservable<TSource>, IScheduler) Returns the source observable sequence or the other observable sequence if dueTime elapses.
Timer(DateTimeOffset) Returns an observable sequence that produces a value at due time.
Timer(TimeSpan) Returns an observable sequence that produces a value after the due time has elapsed.
Timer(DateTimeOffset, IScheduler) Returns an observable sequence that produces a value at due time.
Timer(DateTimeOffset, TimeSpan) Returns an observable sequence that produces a value at due time and then after each period.
Timer(TimeSpan, IScheduler) Returns an observable sequence that produces a value after the due time has elapsed.
Timer(TimeSpan, TimeSpan) Returns an observable sequence that produces a value after due time has elapsed and then after each period.
Timer(DateTimeOffset, TimeSpan, IScheduler) Returns an observable sequence that produces a value at due time and then after each period.
Timer(TimeSpan, TimeSpan, IScheduler) Returns an observable sequence that produces a value after due time has elapsed and then each period.
Timestamp<TSource>(IObservable<TSource>) Records the timestamp for each value in an observable sequence with the specified source.
Timestamp<TSource>(IObservable<TSource>, IScheduler) Records the timestamp for each value in an observable sequence with the specified source and scheduler.
ToArray<TSource> Creates an array from an observable sequence.
ToAsync(Action) Converts the function into an asynchronous function.
ToAsync(Action, IScheduler) Converts the function into an asynchronous function.
ToAsync<TSource>(Action<TSource>) Converts the function into an asynchronous function.
ToAsync<TResult>(Func<TResult>) Converts the function into an asynchronous function.
ToAsync<TSource>(Action<TSource>, IScheduler) Converts the function into an asynchronous function.
ToAsync<TResult>(Func<TResult>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10>(Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10>(Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11>(Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11>(Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12>(Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12>(Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13>(Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13>(Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14>(Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14>(Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15>(Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15>(Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16>(Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TResult>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16>(Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TResult>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TResult>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TResult>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2>(Action<T1, T2>) Converts the function into an asynchronous function.
ToAsync<T, TResult>(Func<T, TResult>) Converts the function into an asynchronous function.
ToAsync<T1, T2>(Action<T1, T2>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T, TResult>(Func<T, TResult>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3>(Action<T1, T2, T3>) Converts the function into an asynchronous function.
ToAsync<T1, T2, TResult>(Func<T1, T2, TResult>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3>(Action<T1, T2, T3>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, TResult>(Func<T1, T2, TResult>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4>(Action<T1, T2, T3, T4>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, TResult>(Func<T1, T2, T3, TResult>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4>(Action<T1, T2, T3, T4>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, TResult>(Func<T1, T2, T3, TResult>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5>(Action<T1, T2, T3, T4, T5>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, TResult>(Func<T1, T2, T3, T4, TResult>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5>(Action<T1, T2, T3, T4, T5>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, TResult>(Func<T1, T2, T3, T4, TResult>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6>(Action<T1, T2, T3, T4, T5, T6>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, TResult>(Func<T1, T2, T3, T4, T5, TResult>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6>(Action<T1, T2, T3, T4, T5, T6>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, TResult>(Func<T1, T2, T3, T4, T5, TResult>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7>(Action<T1, T2, T3, T4, T5, T6, T7>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, TResult>(Func<T1, T2, T3, T4, T5, T6, TResult>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7>(Action<T1, T2, T3, T4, T5, T6, T7>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, TResult>(Func<T1, T2, T3, T4, T5, T6, TResult>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8>(Action<T1, T2, T3, T4, T5, T6, T7, T8>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, TResult>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8>(Action<T1, T2, T3, T4, T5, T6, T7, T8>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, TResult>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9>(Action<T1, T2, T3, T4, T5, T6, T7, T8, T9>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, T8, TResult>) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9>(Action<T1, T2, T3, T4, T5, T6, T7, T8, T9>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2, T3, T4, T5, T6, T7, T8, TResult>(Func<T1, T2, T3, T4, T5, T6, T7, T8, TResult>, IScheduler) Converts the function into an asynchronous function.
ToDictionary<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>) Creates a dictionary from an observable sequence according to a specified key selector function.
ToDictionary<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>, IEqualityComparer<TKey>) Creates a dictionary from an observable sequence according to a specified key selector function, and a comparer.
ToDictionary<TSource, TKey, TElement>(IObservable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>) Creates a dictionary from an observable sequence according to a specified key selector function, and an element selector function.
ToDictionary<TSource, TKey, TElement>(IObservable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>, IEqualityComparer<TKey>) Creates a dictionary from an observable sequence according to a specified key selector function, a comparer, and an element selector function.
ToEnumerable<TSource> Converts an observable sequence to an enumerable sequence.
ToEvent(IObservable<Unit>) Exposes an observable sequence as an object with a .NET event with a specified source.
ToEvent<TSource>(IObservable<TSource>) Exposes an observable sequence as an object with a .NET event with a specified source.
ToEventPattern<TEventArgs> Exposes an observable sequence as an object with a .NET event.
ToList<TSource> Creates a list from an observable sequence.
ToLookup<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>) Creates a lookup from an observable sequence according to a specified key selector function.
ToLookup<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>, IEqualityComparer<TKey>) Creates a lookup from an observable sequence according to a specified key selector function, and a comparer.
ToLookup<TSource, TKey, TElement>(IObservable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>) Creates a lookup from an observable sequence according to a specified key selector function, and an element selector function.
ToLookup<TSource, TKey, TElement>(IObservable<TSource>, Func<TSource, TKey>, Func<TSource, TElement>, IEqualityComparer<TKey>) Creates a lookup from an observable sequence according to a specified key selector function, a comparer, and an element selector function.
ToObservable<TSource>(IEnumerable<TSource>) Converts an enumerable sequence to an observable sequence with a specified source.
ToObservable<TSource>(IEnumerable<TSource>, IScheduler) Converts an enumerable sequence to an observable sequence with a specified source and scheduler.
Using<TSource, TResource> Constructs an observable sequence that depends on a resource object.
When<TResult>(IEnumerable<Plan<TResult>>) Joins together the results from several patterns.
When<TResult>(Plan<TResult>[]) Joins together the results from several patterns.
Where<TSource>(IObservable<TSource>, Func<TSource, Boolean>) Filters the elements of an observable sequence based on a predicate.
Where<TSource>(IObservable<TSource>, Func<TSource, Int32, Boolean>) Filters the elements of an observable sequence based on a predicate by incorporating the element's index.
Window<TSource>(IObservable<TSource>, Int32) Projects each element of an observable sequence into consecutive non-overlapping windows which are produced based on element count information.
Window<TSource>(IObservable<TSource>, TimeSpan) Projects each element of an observable sequence into consecutive non-overlapping windows which are produced based on timing information.
Window<TSource>(IObservable<TSource>, Int32, Int32) Projects each element of an observable sequence into zero or more windows which are produced based on element count information.
Window<TSource>(IObservable<TSource>, TimeSpan, Int32) Projects each element of an observable sequence into a window that is completed when either it’s full or a given amount of time has elapsed.
Window<TSource>(IObservable<TSource>, TimeSpan, IScheduler) Projects each element of an observable sequence into consecutive non-overlapping windows which are produced based on timing information.
Window<TSource>(IObservable<TSource>, TimeSpan, TimeSpan) Projects each element of an observable sequence into zero or more windows which are produced based on timing information.
Window<TSource>(IObservable<TSource>, TimeSpan, Int32, IScheduler) Projects each element of an observable sequence into a window that is completed when either it’s full or a given amount of time has elapsed.
Window<TSource>(IObservable<TSource>, TimeSpan, TimeSpan, IScheduler) Projects each element of an observable sequence into zero or more windows which are produced based on timing information.
Window<TSource, TWindowClosing>(IObservable<TSource>, Func<IObservable<TWindowClosing>>) Projects each element of an observable sequence into consecutive non-overlapping windows.
Window<TSource, TWindowOpening, TWindowClosing>(IObservable<TSource>, IObservable<TWindowOpening>, Func<TWindowOpening, IObservable<TWindowClosing>>) Projects each element of an observable sequence into zero or more windows.
Zip<TFirst, TSecond, TResult>(IObservable<TFirst>, IEnumerable<TSecond>, Func<TFirst, TSecond, TResult>) Merges an observable sequence and an enumerable sequence into one observable sequence by using the selector function.
Zip<TFirst, TSecond, TResult>(IObservable<TFirst>, IObservable<TSecond>, Func<TFirst, TSecond, TResult>) Merges two observable sequences into one observable sequence by combining their elements in a pairwise fashion.

Top