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