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
Public methodStatic member Aggregate<TSource>(IObservable<TSource>, Func<TSource, TSource, TSource>) Applies an accumulator function over an observable sequence.
Public methodStatic member Aggregate<TSource, TAccumulate>(IObservable<TSource>, TAccumulate, Func<TAccumulate, TSource, TAccumulate>) Applies an accumulator function over an observable sequence with the specified seed value.
Public methodStatic member All<TSource> Determines whether all elements of an observable sequence satisfies a condition.
Public methodStatic member Amb<TSource>(IEnumerable<IObservable<TSource>>) Propagates the observable sequence that reacts first with a specified sources.
Public methodStatic member Amb<TSource>(IObservable<TSource>[]) Propagates the observable sequence that reacts first with a specified sources.
Public methodStatic member Amb<TSource>(IObservable<TSource>, IObservable<TSource>) Propagates the observable sequence that reacts first with the specified first and second sequence.
Public methodStatic member And<TLeft, TRight> Matches when both observable sequences have an available value.
Public methodStatic member Any<TSource>(IObservable<TSource>) Determines whether an observable sequence contains any elements.
Public methodStatic member Any<TSource>(IObservable<TSource>, Func<TSource, Boolean>) Determines whether all elements of an observable sequence satisfies a condition.
Public methodStatic member AsObservable<TSource> Hides the identity of an observable sequence.
Public methodStatic member Average(IObservable<Decimal>) Computes the average of an observable sequence of Decimal values.
Public methodStatic member Average(IObservable<Double>) Computes the average of an observable sequence of Double values.
Public methodStatic member Average(IObservable<Int32>) Computes the average of an observable sequence of Int32 values.
Public methodStatic member Average(IObservable<Int64>) Computes the average of an observable sequence of Int64 values.
Public methodStatic member Average(IObservable<Nullable<Decimal>>) Computes the average of an observable sequence of nullable Decimal values.
Public methodStatic member Average(IObservable<Nullable<Double>>) Computes the average of an observable sequence of nullable Double values.
Public methodStatic member Average(IObservable<Nullable<Int32>>) Computes the average of an observable sequence of nullable Int32 values.
Public methodStatic member Average(IObservable<Nullable<Int64>>) Computes the average of an observable sequence of nullable Int64 values.
Public methodStatic member Average(IObservable<Nullable<Single>>) Computes the average of an observable sequence of nullable Float values.
Public methodStatic member Average(IObservable<Single>) Computes the average of an observable sequence of Float values.
Public methodStatic member 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.
Public methodStatic member Buffer<TSource>(IObservable<TSource>, TimeSpan) Indicates each element of an observable sequence into consecutive non-overlapping buffers which are produced based on timing information.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member Buffer<TSource, TBufferClosing>(IObservable<TSource>, Func<IObservable<TBufferClosing>>) Indicates each element of an observable sequence into consecutive non-overlapping buffers.
Public methodStatic member 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.
Public methodStatic member Cast<TResult> Converts the elements of an observable sequence to the specified type.
Public methodStatic member Catch<TSource>(IEnumerable<IObservable<TSource>>) Continues an observable sequence that is terminated by an exception with the next observable sequence.
Public methodStatic member Catch<TSource>(IObservable<TSource>[]) Continues an observable sequence that is terminated by an exception with the next observable sequence.
Public methodStatic member Catch<TSource>(IObservable<TSource>, IObservable<TSource>) Continues an observable sequence that is terminated by an exception with the next observable sequence.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member Concat<TSource>(IEnumerable<IObservable<TSource>>) Concatenates an enumerable sequence of observable sequences.
Public methodStatic member Concat<TSource>(IObservable<IObservable<TSource>>) Concatenates an observable sequence of observable sequences.
Public methodStatic member Concat<TSource>(IObservable<TSource>[]) Concatenates all the observable sequences.
Public methodStatic member Concat<TSource>(IObservable<TSource>, IObservable<TSource>) Concatenates two observable sequences.
Public methodStatic member Contains<TSource>(IObservable<TSource>, TSource) Determines whether an observable sequence contains a specified element by using the default equality comparer.
Public methodStatic member 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;.
Public methodStatic member Count<TSource> Returns a Int32 that represents the total number of elements in an observable sequence.
Public methodStatic member Create<TSource>(Func<IObserver<TSource>, Action>) Creates an observable sequence from a specified subscribe method implementation with a specified subscribe.
Public methodStatic member Create<TSource>(Func<IObserver<TSource>, IDisposable>) Creates an observable sequence from a subscribe method implementation.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member Defer<TValue> Returns an observable sequence that invokes the observable factory whenever a new observer subscribes.
Public methodStatic member Delay<TSource>(IObservable<TSource>, DateTimeOffset) Indicates the observable sequence by due time with the specified source and dueTime.
Public methodStatic member Delay<TSource>(IObservable<TSource>, TimeSpan) Indicates the observable sequence by due time with the specified source and dueTime.
Public methodStatic member Delay<TSource>(IObservable<TSource>, DateTimeOffset, IScheduler) Indicates the observable sequence by due time with the specified source, dueTime and scheduler.
Public methodStatic member Delay<TSource>(IObservable<TSource>, TimeSpan, IScheduler) Indicates the observable sequence by due time with the specified source, dueTime and scheduler.
Public methodStatic member Dematerialize<TSource> Dematerializes the explicit notification values of an observable sequence as implicit notifications.
Public methodStatic member Distinct<TSource>(IObservable<TSource>) Returns an observable sequence that contains only distinct elements with a specified source.
Public methodStatic member Distinct<TSource>(IObservable<TSource>, IEqualityComparer<TSource>) Returns an observable sequence that contains only distinct elements according to the comparer.
Public methodStatic member Distinct<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>) Returns an observable sequence that contains only distinct elements according to the keySelector.
Public methodStatic member Distinct<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>, IEqualityComparer<TKey>) Returns an observable sequence that contains only distinct elements according to the keySelector.
Public methodStatic member DistinctUntilChanged<TSource>(IObservable<TSource>) Returns an observable sequence that contains only distinct contiguous elements with a specified source.
Public methodStatic member DistinctUntilChanged<TSource>(IObservable<TSource>, IEqualityComparer<TSource>) Returns an observable sequence that contains only distinct contiguous elements according to the comparer.
Public methodStatic member DistinctUntilChanged<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>) Returns an observable sequence that contains only distinct contiguous elements according to the keySelector.
Public methodStatic member 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.
Public methodStatic member Do<TSource>(IObservable<TSource>, Action<TSource>) Invokes an action for each element in the observable sequence.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member ElementAt<TSource> Returns the element at a specified index in a sequence.
Public methodStatic member ElementAtOrDefault<TSource> Returns the element at a specified index in a sequence or a default value if the index is out of range.
Public methodStatic member Empty<TResult>() Returns an empty observable sequence.
Public methodStatic member Empty<TResult>(IScheduler) Returns an empty observable sequence with the specified scheduler.
Public methodStatic member Finally<TSource> Invokes a specified action after source observable sequence terminates normally or by an exception.
Public methodStatic member First<TSource>(IObservable<TSource>) Returns the first element of an observable sequence with a specified source.
Public methodStatic member First<TSource>(IObservable<TSource>, Func<TSource, Boolean>) Returns the first element of an observable sequence that matches the predicate.
Public methodStatic member FirstOrDefault<TSource>(IObservable<TSource>) Returns the first element of an observable sequence, or a default value if no value is found.
Public methodStatic member 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.
Public methodStatic member ForEach<TSource> Invokes an action for each element in the observable sequence, and blocks until the sequence is terminated.
Public methodStatic member FromAsyncPattern(Func<AsyncCallback, Object, IAsyncResult>, Action<IAsyncResult>) Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic member FromAsyncPattern<TResult>(Func<AsyncCallback, Object, IAsyncResult>, Func<IAsyncResult, TResult>) Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic member FromAsyncPattern<T1>(Func<T1, AsyncCallback, Object, IAsyncResult>, Action<IAsyncResult>) Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member FromAsyncPattern<T1, TResult>(Func<T1, AsyncCallback, Object, IAsyncResult>, Func<IAsyncResult, TResult>) Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic member FromAsyncPattern<T1, T2>(Func<T1, T2, AsyncCallback, Object, IAsyncResult>, Action<IAsyncResult>) Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic member FromAsyncPattern<T1, T2, TResult>(Func<T1, T2, AsyncCallback, Object, IAsyncResult>, Func<IAsyncResult, TResult>) Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic member FromAsyncPattern<T1, T2, T3>(Func<T1, T2, T3, AsyncCallback, Object, IAsyncResult>, Action<IAsyncResult>) Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member FromEvent(Action<Action>, Action<Action>) Converts a .NET event to an observable sequence.
Public methodStatic member FromEvent<TEventArgs>(Action<Action<TEventArgs>>, Action<Action<TEventArgs>>) Converts a .NET event to an observable sequence.
Public methodStatic member FromEvent<TDelegate, TEventArgs>(Action<TDelegate>, Action<TDelegate>) Converts a .NET event to an observable sequence.
Public methodStatic member FromEvent<TDelegate, TEventArgs>(Func<Action<TEventArgs>, TDelegate>, Action<TDelegate>, Action<TDelegate>) Converts a .NET event to an observable sequence.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member GetEnumerator<TSource> Returns an enumerator that enumerates all values of the observable sequence.
Public methodStatic member GroupBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>) Groups the elements of an observable sequence according to a specified key selector function.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member GroupJoin<TLeft, TRight, TLeftDuration, TRightDuration, TResult> Correlates the elements of two sequences based on overlapping durations, and groups the results.
Public methodStatic member IgnoreElements<TSource> Ignores all values in an observable sequence leaving only the termination messages.
Public methodStatic member Interval(TimeSpan) Returns an observable sequence that produces a value after each period.
Public methodStatic member Interval(TimeSpan, IScheduler) Returns an observable sequence that produces a value after each period.
Public methodStatic member Join<TLeft, TRight, TLeftDuration, TRightDuration, TResult> Correlates the elements of two sequences based on overlapping durations.
Public methodStatic member Last<TSource>(IObservable<TSource>) Returns the last element of an observable sequence with a specified source.
Public methodStatic member Last<TSource>(IObservable<TSource>, Func<TSource, Boolean>) Returns the last element of an observable sequence that matches the predicate.
Public methodStatic member LastOrDefault<TSource>(IObservable<TSource>) Returns last element in the observable sequence, or a default value if no value is found.
Public methodStatic member 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.
Public methodStatic member Latest<TSource> Samples the most recent value in an observable sequence.
Public methodStatic member LongCount<TSource> Returns a Int64 that represents the total number of elements in an observable sequence.
Public methodStatic member Materialize<TSource> Materializes the implicit notifications of an observable sequence as explicit notification values.
Public methodStatic member Max(IObservable<Decimal>) Returns the maximum value in an observable sequence of Decimal values.
Public methodStatic member Max(IObservable<Double>) Returns the maximum value in an observable sequence of Double values.
Public methodStatic member Max(IObservable<Int32>) Returns the maximum value in an observable sequence of Int32 values.
Public methodStatic member Max(IObservable<Int64>) Returns the maximum value in an observable sequence of Int64 values.
Public methodStatic member Max(IObservable<Nullable<Decimal>>) Returns the maximum value in an observable sequence of nullable Decimal values.
Public methodStatic member Max(IObservable<Nullable<Double>>) Returns the maximum value in an observable sequence of nullable Double values.
Public methodStatic member Max(IObservable<Nullable<Int32>>) Returns the maximum value in an observable sequence of nullable Int32 values.
Public methodStatic member Max(IObservable<Nullable<Int64>>) Returns the maximum value in an observable sequence of nullable Int64 values.
Public methodStatic member Max(IObservable<Nullable<Single>>) Returns the maximum value in an observable sequence of nullable Float values.
Public methodStatic member Max(IObservable<Single>) Returns the maximum value in an observable sequence of Float values.
Public methodStatic member Max<TSource>(IObservable<TSource>) Returns the maximum element in an observable sequence.
Public methodStatic member Max<TSource>(IObservable<TSource>, IComparer<TSource>) Returns the maximum value in an observable sequence according to the specified comparer.
Public methodStatic member MaxBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>) Returns the elements in an observable sequence with the maximum key value.
Public methodStatic member MaxBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>, IComparer<TKey>) Returns the elements in an observable sequence with the maximum key value.
Public methodStatic member Merge<TSource>(IEnumerable<IObservable<TSource>>) Merges an enumerable sequence of observable sequences into a single observable sequence.
Public methodStatic member Merge<TSource>(IObservable<IObservable<TSource>>) Merges an observable sequence of observable sequences into an observable sequence.
Public methodStatic member Merge<TSource>(IObservable<TSource>[]) Merges all the observable sequences into a single observable sequence.
Public methodStatic member 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.
Public methodStatic member Merge<TSource>(IEnumerable<IObservable<TSource>>, IScheduler) Merges an enumerable sequence of observable sequences into a single observable sequence.
Public methodStatic member 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.
Public methodStatic member Merge<TSource>(IObservable<TSource>, IObservable<TSource>) Merges an observable sequence of observable sequences into an observable sequence.
Public methodStatic member Merge<TSource>(IScheduler, IObservable<TSource>[]) Merges all the observable sequences into a single observable sequence.
Public methodStatic member 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.
Public methodStatic member Merge<TSource>(IObservable<TSource>, IObservable<TSource>, IScheduler) Merges two observable sequences into a single observable sequence.
Public methodStatic member Min(IObservable<Decimal>) Returns the minimum value in an observable sequence of Decimal values.
Public methodStatic member Min(IObservable<Double>) Returns the minimum value in an observable sequence of Double values.
Public methodStatic member Min(IObservable<Int32>) Returns the minimum value in an observable sequence of Int32 values.
Public methodStatic member Min(IObservable<Int64>) Returns the minimum value in an observable sequence of Int64 values.
Public methodStatic member Min(IObservable<Nullable<Decimal>>) Returns the minimum value in an observable sequence of nullable Decimal values.
Public methodStatic member Min(IObservable<Nullable<Double>>) Returns the minimum value in an observable sequence of nullable Double values.
Public methodStatic member Min(IObservable<Nullable<Int32>>) Returns the minimum value in an observable sequence of nullable Int32 values.
Public methodStatic member Min(IObservable<Nullable<Int64>>) Returns the minimum value in an observable sequence of nullable Int64 values.
Public methodStatic member Min(IObservable<Nullable<Single>>) Returns the minimum value in an observable sequence of nullable Float values.
Public methodStatic member Min(IObservable<Single>) Returns the minimum value in an observable sequence of Float values.
Public methodStatic member Min<TSource>(IObservable<TSource>) Returns the minimum element in an observable sequence.
Public methodStatic member Min<TSource>(IObservable<TSource>, IComparer<TSource>) Returns the minimum value in an observable sequence according to the specified comparer.
Public methodStatic member MinBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>) Returns the elements in an observable sequence with the minimum key value.
Public methodStatic member 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.
Public methodStatic member MostRecent<TSource> Samples the most recent value in an observable sequence.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member Never<TResult> Returns a non-terminating observable sequence.
Public methodStatic member Next<TSource> Samples the next value (blocking without buffering) from in an observable sequence.
Public methodStatic member ObserveOn<TSource>(IObservable<TSource>, IScheduler) Asynchronously notify observers on the specified scheduler.
Public methodStatic member ObserveOn<TSource>(IObservable<TSource>, SynchronizationContext) Asynchronously notify observers on the specified synchronization context.
Public methodStatic member OfType<TResult> Filters the elements of an observable sequence based on the specified type.
Public methodStatic member OnErrorResumeNext<TSource>(IEnumerable<IObservable<TSource>>) Continues an observable sequence that is terminated normally or by an exception with the next observable sequence.
Public methodStatic member OnErrorResumeNext<TSource>(IObservable<TSource>[]) Continues an observable sequence that is terminated normally or by an exception with the next observable sequence.
Public methodStatic member OnErrorResumeNext<TSource>(IObservable<TSource>, IObservable<TSource>) Continues an observable sequence that is terminated normally or by an exception with the next observable sequence.
Public methodStatic member Publish<TSource>(IObservable<TSource>) Returns a connectable observable sequence that shares a single subscription to the underlying sequence.
Public methodStatic member Publish<TSource>(IObservable<TSource>, TSource) Returns a connectable observable sequence that shares a single subscription to the underlying sequence and starts with initialValue.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member PublishLast<TSource>(IObservable<TSource>) Returns a connectable observable sequence that shares a single subscription to the underlying sequence containing only the last notification.
Public methodStatic member 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.
Public methodStatic member Range(Int32, Int32) Generates an observable sequence of integral numbers within a specified range.
Public methodStatic member Range(Int32, Int32, IScheduler) Generates an observable sequence of integral numbers within a specified range.
Public methodStatic member 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.
Public methodStatic member Repeat<TSource>(IObservable<TSource>) Repeats the observable sequence indefinitely.
Public methodStatic member Repeat<TResult>(TResult) Generates an observable sequence that repeats the given element infinitely.
Public methodStatic member Repeat<TSource>(IObservable<TSource>, Int32) Repeats the observable sequence indefinitely.
Public methodStatic member Repeat<TResult>(TResult, Int32) Generates an observable sequence that repeats the given element the specified number of times.
Public methodStatic member Repeat<TResult>(TResult, IScheduler) Generates an observable sequence that repeats the given element infinitely.
Public methodStatic member Repeat<TResult>(TResult, Int32, IScheduler) Generates an observable sequence that repeats the given element of the specified number of times.
Public methodStatic member Replay<TSource>(IObservable<TSource>) Returns a connectable observable sequence that shares a single subscription to the underlying sequence replaying all notifications.
Public methodStatic member Replay<TSource>(IObservable<TSource>, Int32) Returns a connectable observable sequence that shares a single subscription to the underlying sequence replaying bufferSize notifications.
Public methodStatic member Replay<TSource>(IObservable<TSource>, IScheduler) Returns a connectable observable sequence that shares a single subscription to the underlying sequence replaying all notifications.
Public methodStatic member Replay<TSource>(IObservable<TSource>, TimeSpan) Returns a connectable observable sequence that shares a single subscription to the underlying sequence replaying all notifications within window.
Public methodStatic member Replay<TSource>(IObservable<TSource>, Int32, IScheduler) Returns a connectable observable sequence that shares a single subscription to the underlying sequence replaying bufferSize notifications.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member Retry<TSource>(IObservable<TSource>) Repeats the source observable sequence until it successfully terminates.
Public methodStatic member Retry<TSource>(IObservable<TSource>, Int32) Repeats the source observable sequence until it successfully terminates.
Public methodStatic member Return<TResult>(TResult) Returns an observable sequence that contains a single element with a specified value.
Public methodStatic member Return<TResult>(TResult, IScheduler) Returns an observable sequence that contains a single value with a specified value and scheduler.
Public methodStatic member Sample<TSource>(IObservable<TSource>, TimeSpan) Samples the observable sequence at each interval.
Public methodStatic member Sample<TSource>(IObservable<TSource>, TimeSpan, IScheduler) Samples the observable sequence at each interval with the specified source, interval and scheduler.
Public methodStatic member Sample<TSource, TSample>(IObservable<TSource>, IObservable<TSample>) Samples the observable sequence at sampling ticks with the specified source and sampler.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member SequenceEqual<TSource>(IObservable<TSource>, IObservable<TSource>) Determines whether two sequences are equal by comparing the elements pairwise.
Public methodStatic member SequenceEqual<TSource>(IObservable<TSource>, IObservable<TSource>, IEqualityComparer<TSource>) Determines whether two sequences are equal by comparing the elements pairwise using a specified equality comparer.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member SingleOrDefault<TSource>(IObservable<TSource>) Returns the only element of an observable sequence, or a default value if the observable sequence is empty.
Public methodStatic member 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.
Public methodStatic member Skip<TSource> Bypasses a specified number of values in an observable sequence and then returns the remaining values.
Public methodStatic member SkipLast<TSource> Bypasses a specified number of elements at the end of an observable sequence.
Public methodStatic member SkipUntil<TSource, TOther> Returns the values from the source observable sequence only after the other observable sequence produces a value.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member Start(Action) Invokes the action asynchronously.
Public methodStatic member Start(Action, IScheduler) Invokes the action asynchronously.
Public methodStatic member Start<TSource>(Func<TSource>) Invokes the function asynchronously.
Public methodStatic member Start<TSource>(Func<TSource>, IScheduler) Invokes the function asynchronously.
Public methodStatic member StartWith<TSource>(IObservable<TSource>, TSource[]) Prepends a sequence of values to an observable sequence with the specified source and values.
Public methodStatic member StartWith<TSource>(IObservable<TSource>, IScheduler, TSource[]) Prepends a sequence of values to an observable sequence with the specified source, scheduler and values.
Public methodStatic member Subscribe<TSource>(IEnumerable<TSource>, IObserver<TSource>) Subscribes an observer to an enumerable sequence with the specified source and observer.
Public methodStatic member Subscribe<TSource>(IEnumerable<TSource>, IObserver<TSource>, IScheduler) Subscribes an observer to an enumerable sequence with the specified source and observer.
Public methodStatic member SubscribeOn<TSource>(IObservable<TSource>, IScheduler) Asynchronously subscribes and unsubscribes observers on the specified scheduler.
Public methodStatic member SubscribeOn<TSource>(IObservable<TSource>, SynchronizationContext) Asynchronously subscribes and unsubscribes observers on the specified synchronization context.
Public methodStatic member Sum(IObservable<Decimal>) Computes the sum of a sequence of Decimal values.
Public methodStatic member Sum(IObservable<Double>) Computes the sum of a sequence of Double values.
Public methodStatic member Sum(IObservable<Int32>) Computes the sum of a sequence of Int32 values.
Public methodStatic member Sum(IObservable<Int64>) Computes the sum of a sequence of Int64 values.
Public methodStatic member Sum(IObservable<Nullable<Decimal>>) Computes the sum of a sequence of nullable Decimal values.
Public methodStatic member Sum(IObservable<Nullable<Double>>) Computes the sum of a sequence of nullable Double values.
Public methodStatic member Sum(IObservable<Nullable<Int32>>) Computes the sum of a sequence of nullable Int32 values.
Public methodStatic member Sum(IObservable<Nullable<Int64>>) Computes the sum of a sequence of nullable Int64 values.
Public methodStatic member Sum(IObservable<Nullable<Single>>) Computes the sum of a sequence of nullable Float values.
Public methodStatic member Sum(IObservable<Single>) Computes the sum of a sequence of Float values.
Public methodStatic member Switch<TSource> Transforms an observable sequence of observable sequences into an observable sequence producing values only from the most recent observable sequence.
Public methodStatic member Synchronize<TSource>(IObservable<TSource>) Synchronizes the observable sequence.
Public methodStatic member Synchronize<TSource>(IObservable<TSource>, Object) Synchronizes the observable sequence.
Public methodStatic member Take<TSource> Returns a specified number of contiguous values from the start of an observable sequence.
Public methodStatic member TakeLast<TSource> Returns a specified number of contiguous elements from the end of an observable sequence.
Public methodStatic member TakeUntil<TSource, TOther> Returns the values from the source observable sequence until the other observable sequence produces a value.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member Then<TSource, TResult> Matches when the observable sequence has an available value and projects the value.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member Throw<TResult>(Exception) Returns an observable sequence that terminates with an exception.
Public methodStatic member Throw<TResult>(Exception, IScheduler) Returns an observable sequence that terminates with an exception with the specified scheduler.
Public methodStatic member TimeInterval<TSource>(IObservable<TSource>) Records the time interval between consecutive values in an observable sequence with the specified source.
Public methodStatic member TimeInterval<TSource>(IObservable<TSource>, IScheduler) Records the time interval between consecutive values in an observable sequence with the specified source and scheduler.
Public methodStatic member Timeout<TSource>(IObservable<TSource>, DateTimeOffset) Returns either the observable sequence or a TimeoutException if dueTime elapses.
Public methodStatic member Timeout<TSource>(IObservable<TSource>, TimeSpan) Returns either the observable sequence or an TimeoutException if dueTime elapses.
Public methodStatic member Timeout<TSource>(IObservable<TSource>, DateTimeOffset, IObservable<TSource>) Returns either the observable sequence or an TimeoutException if dueTime elapses.
Public methodStatic member Timeout<TSource>(IObservable<TSource>, DateTimeOffset, IScheduler) Returns either the observable sequence or an TimeoutException if dueTime elapses.
Public methodStatic member Timeout<TSource>(IObservable<TSource>, TimeSpan, IObservable<TSource>) Returns the source observable sequence or the other observable sequence if dueTime elapses.
Public methodStatic member Timeout<TSource>(IObservable<TSource>, TimeSpan, IScheduler) Returns either the observable sequence or an TimeoutException if dueTime elapses.
Public methodStatic member Timeout<TSource>(IObservable<TSource>, DateTimeOffset, IObservable<TSource>, IScheduler) Returns the source observable sequence or the other observable sequence if dueTime elapses.
Public methodStatic member Timeout<TSource>(IObservable<TSource>, TimeSpan, IObservable<TSource>, IScheduler) Returns the source observable sequence or the other observable sequence if dueTime elapses.
Public methodStatic member Timer(DateTimeOffset) Returns an observable sequence that produces a value at due time.
Public methodStatic member Timer(TimeSpan) Returns an observable sequence that produces a value after the due time has elapsed.
Public methodStatic member Timer(DateTimeOffset, IScheduler) Returns an observable sequence that produces a value at due time.
Public methodStatic member Timer(DateTimeOffset, TimeSpan) Returns an observable sequence that produces a value at due time and then after each period.
Public methodStatic member Timer(TimeSpan, IScheduler) Returns an observable sequence that produces a value after the due time has elapsed.
Public methodStatic member Timer(TimeSpan, TimeSpan) Returns an observable sequence that produces a value after due time has elapsed and then after each period.
Public methodStatic member Timer(DateTimeOffset, TimeSpan, IScheduler) Returns an observable sequence that produces a value at due time and then after each period.
Public methodStatic member Timer(TimeSpan, TimeSpan, IScheduler) Returns an observable sequence that produces a value after due time has elapsed and then each period.
Public methodStatic member Timestamp<TSource>(IObservable<TSource>) Records the timestamp for each value in an observable sequence with the specified source.
Public methodStatic member Timestamp<TSource>(IObservable<TSource>, IScheduler) Records the timestamp for each value in an observable sequence with the specified source and scheduler.
Public methodStatic member ToArray<TSource> Creates an array from an observable sequence.
Public methodStatic member ToAsync(Action) Converts the function into an asynchronous function.
Public methodStatic member ToAsync(Action, IScheduler) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<TSource>(Action<TSource>) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<TResult>(Func<TResult>) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<TSource>(Action<TSource>, IScheduler) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<TResult>(Func<TResult>, IScheduler) Converts the function into an asynchronous function.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member ToAsync<T1, T2>(Action<T1, T2>) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<T, TResult>(Func<T, TResult>) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<T1, T2>(Action<T1, T2>, IScheduler) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<T, TResult>(Func<T, TResult>, IScheduler) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<T1, T2, T3>(Action<T1, T2, T3>) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<T1, T2, TResult>(Func<T1, T2, TResult>) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<T1, T2, T3>(Action<T1, T2, T3>, IScheduler) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<T1, T2, TResult>(Func<T1, T2, TResult>, IScheduler) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<T1, T2, T3, T4>(Action<T1, T2, T3, T4>) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<T1, T2, T3, TResult>(Func<T1, T2, T3, TResult>) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<T1, T2, T3, T4>(Action<T1, T2, T3, T4>, IScheduler) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<T1, T2, T3, TResult>(Func<T1, T2, T3, TResult>, IScheduler) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<T1, T2, T3, T4, T5>(Action<T1, T2, T3, T4, T5>) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<T1, T2, T3, T4, TResult>(Func<T1, T2, T3, T4, TResult>) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<T1, T2, T3, T4, T5>(Action<T1, T2, T3, T4, T5>, IScheduler) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<T1, T2, T3, T4, TResult>(Func<T1, T2, T3, T4, TResult>, IScheduler) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<T1, T2, T3, T4, T5, T6>(Action<T1, T2, T3, T4, T5, T6>) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<T1, T2, T3, T4, T5, TResult>(Func<T1, T2, T3, T4, T5, TResult>) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<T1, T2, T3, T4, T5, T6>(Action<T1, T2, T3, T4, T5, T6>, IScheduler) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<T1, T2, T3, T4, T5, TResult>(Func<T1, T2, T3, T4, T5, TResult>, IScheduler) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<T1, T2, T3, T4, T5, T6, T7>(Action<T1, T2, T3, T4, T5, T6, T7>) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<T1, T2, T3, T4, T5, T6, TResult>(Func<T1, T2, T3, T4, T5, T6, TResult>) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<T1, T2, T3, T4, T5, T6, T7>(Action<T1, T2, T3, T4, T5, T6, T7>, IScheduler) Converts the function into an asynchronous function.
Public methodStatic member ToAsync<T1, T2, T3, T4, T5, T6, TResult>(Func<T1, T2, T3, T4, T5, T6, TResult>, IScheduler) Converts the function into an asynchronous function.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member ToDictionary<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>) Creates a dictionary from an observable sequence according to a specified key selector function.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member ToEnumerable<TSource> Converts an observable sequence to an enumerable sequence.
Public methodStatic member ToEvent(IObservable<Unit>) Exposes an observable sequence as an object with a .NET event with a specified source.
Public methodStatic member ToEvent<TSource>(IObservable<TSource>) Exposes an observable sequence as an object with a .NET event with a specified source.
Public methodStatic member ToEventPattern<TEventArgs> Exposes an observable sequence as an object with a .NET event.
Public methodStatic member ToList<TSource> Creates a list from an observable sequence.
Public methodStatic member ToLookup<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>) Creates a lookup from an observable sequence according to a specified key selector function.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member ToObservable<TSource>(IEnumerable<TSource>) Converts an enumerable sequence to an observable sequence with a specified source.
Public methodStatic member ToObservable<TSource>(IEnumerable<TSource>, IScheduler) Converts an enumerable sequence to an observable sequence with a specified source and scheduler.
Public methodStatic member Using<TSource, TResource> Constructs an observable sequence that depends on a resource object.
Public methodStatic member When<TResult>(IEnumerable<Plan<TResult>>) Joins together the results from several patterns.
Public methodStatic member When<TResult>(Result>[]) Joins together the results from several patterns.
Public methodStatic member Where<TSource>(IObservable<TSource>, Func<TSource, Boolean>) Filters the elements of an observable sequence based on a predicate.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member Window<TSource>(IObservable<TSource>, TimeSpan) Projects each element of an observable sequence into consecutive non-overlapping windows which are produced based on timing information.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member 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.
Public methodStatic member Window<TSource, TWindowClosing>(IObservable<TSource>, Func<IObservable<TWindowClosing>>) Projects each element of an observable sequence into consecutive non-overlapping windows.
Public methodStatic member Window<TSource, TWindowOpening, TWindowClosing>(IObservable<TSource>, IObservable<TWindowOpening>, Func<TWindowOpening, IObservable<TWindowClosing>>) Projects each element of an observable sequence into zero or more windows.
Public methodStatic member 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.
Public methodStatic member 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.

See Also

Reference

System.Reactive.Linq Namespace