Share via


Qbservable Class

Represents a queryable observable sequence.

Inheritance Hierarchy

System.Object
  System.Reactive.Linq.Qbservable

Namespace:  System.Reactive.Linq
Assembly:  System.Reactive.Providers (in System.Reactive.Providers.dll)

Syntax

'Declaration
<ExtensionAttribute> _
Public NotInheritable Class Qbservable
'Usage
public static class Qbservable
[ExtensionAttribute]
public ref class Qbservable abstract sealed
[<AbstractClassAttribute>]
[<SealedAttribute>]
type Qbservable =  class end
public final class Qbservable

The Qbservable type exposes the following members.

Properties

  Name Description
Public propertyStatic member Provider Gets the local Qbservable provider.

Top

Methods

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