Observable Class
Provides a set of static methods for query operations over observable sequences.
Inheritance Hierarchy
System.Object
System.Reactive.Linq.Observable
Namespace: System.Reactive.Linq
Assembly: System.Reactive (in System.Reactive.dll)
Syntax
'Declaration
<ExtensionAttribute> _
Public NotInheritable Class Observable
'Usage
public static class Observable
[ExtensionAttribute]
public ref class Observable abstract sealed
[<AbstractClassAttribute>]
[<SealedAttribute>]
type Observable = class end
public final class Observable
The Observable type exposes the following members.
Methods
| Name | Description | |
|---|---|---|
.gif "Public method") .gif "Static member") |
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<T>. |
|
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>(Result>[]) | 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
Thread Safety
Any public static (Shared in Visual Basic) members of this type are thread safe. Any instance members are not guaranteed to be thread safe.