Export (0) Print
Expand All
Expand Minimize

Observable Methods

The Observable type exposes the following members.

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