Export (0) Print
Expand All
Expand Minimize

Qbservable Methods

The Qbservable type exposes the following members.

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