Export (0) Print
Expand All

Qbservable Class

Represents a queryable observable sequence.

System.Object
  System.Reactive.Linq.Qbservable

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

public static class Qbservable

The Qbservable type exposes the following members.

  NameDescription
Public propertyStatic memberProviderGets the local Qbservable provider.
Top

  NameDescription
Public methodStatic memberAggregate<TSource>(IQbservable<TSource>, Expression<Func<TSource, TSource, TSource>>)Applies an accumulator function over a queryable observable sequence.
Public methodStatic memberAggregate<TSource, TAccumulate>(IQbservable<TSource>, TAccumulate, Expression<Func<TAccumulate, TSource, TAccumulate>>)Applies an accumulator function over a queryable observable sequence.
Public methodStatic memberAll<TSource>Determines whether all elements of a queryable observable sequence satisfies a condition.
Public methodStatic memberAmb<TSource>(IQbservable<TSource>, IObservable<TSource>)Propagates the queryable observable sequence that reacts first with the specified first and second sequence.
Public methodStatic memberAmb<TSource>(IQbservableProvider, IEnumerable<IObservable<TSource>>)Propagates the queryable observable sequence that reacts first with a specified sources.
Public methodStatic memberAmb<TSource>(IQbservableProvider, IObservable<TSource>[])Propagates the queryable observable sequence that reacts first with a specified sources.
Public methodStatic memberAnd<TLeft, TRight>Matches when both queryable observable sequences have an available value.
Public methodStatic memberAny<TSource>(IQbservable<TSource>)Determines whether a queryable observable sequence contains any elements.
Public methodStatic memberAny<TSource>(IQbservable<TSource>, Expression<Func<TSource, Boolean>>)Determines whether all elements of a queryable observable sequence satisfies a condition.
Public methodStatic memberAsObservable<TSource>Hides the identity of an observable sequence.
Public methodStatic memberAsQbservable<TSource>Converts an observable sequence into a queryable observable sequence.
Public methodStatic memberAverage(IQbservable<Decimal>)Computes the average of a queryable observable sequence of Decimal values.
Public methodStatic memberAverage(IQbservable<Double>)Computes the average of a queryable observable sequence of Double values.
Public methodStatic memberAverage(IQbservable<Int32>)Computes the average of a queryable observable sequence of Int32 values.
Public methodStatic memberAverage(IQbservable<Int64>)Computes the average of a queryable observable sequence of Int64 values.
Public methodStatic memberAverage(IQbservable<Nullable<Decimal>>)Computes the average of a queryable observable sequence of nullable Decimal values.
Public methodStatic memberAverage(IQbservable<Nullable<Double>>)Computes the average of a queryable observable sequence of nullable Double values.
Public methodStatic memberAverage(IQbservable<Nullable<Int32>>)Computes the average of a queryable observable sequence of nullable Int32 values.
Public methodStatic memberAverage(IQbservable<Nullable<Int64>>)Computes the average of a queryable observable sequence of nullable Int64 values.
Public methodStatic memberAverage(IQbservable<Nullable<Single>>)Computes the average of a queryable observable sequence of nullable Float values.
Public methodStatic memberAverage(IQbservable<Single>)Computes the average of a queryable observable sequence of Float values.
Public methodStatic memberBuffer<TSource>(IQbservable<TSource>, Int32)Indicates each element of a queryable observable sequence into consecutive non-overlapping buffers which are produced based on element count information.
Public methodStatic memberBuffer<TSource>(IQbservable<TSource>, TimeSpan)Indicates each element of a queryable observable sequence into consecutive non-overlapping buffers which are produced based on timing information.
Public methodStatic memberBuffer<TSource>(IQbservable<TSource>, Int32, Int32)Indicates each element of a queryable observable sequence into zero or more buffers which are produced based on element count information.
Public methodStatic memberBuffer<TSource>(IQbservable<TSource>, TimeSpan, Int32)Indicates each element of a queryable observable sequence into a buffer that’s sent out when either it’s full or a given amount of time has elapsed.
Public methodStatic memberBuffer<TSource>(IQbservable<TSource>, TimeSpan, IScheduler)Indicates each element of a queryable observable sequence into consecutive non-overlapping buffers which are produced based on timing information.
Public methodStatic memberBuffer<TSource>(IQbservable<TSource>, TimeSpan, TimeSpan)Indicates each element of a queryable observable sequence into zero or more buffers which are produced based on timing information.
Public methodStatic memberBuffer<TSource>(IQbservable<TSource>, TimeSpan, Int32, IScheduler)Indicates each element of a queryable observable sequence into a buffer that’s sent out when either it’s full or a given amount of time has elapsed.
Public methodStatic memberBuffer<TSource>(IQbservable<TSource>, TimeSpan, TimeSpan, IScheduler)Indicates each element of a queryable observable sequence into zero or more buffers which are produced based on timing information.
Public methodStatic memberBuffer<TSource, TBufferClosing>(IQbservable<TSource>, Expression<Func<IObservable<TBufferClosing>>>)Indicates each element of a queryable observable sequence into consecutive non-overlapping buffers.
Public methodStatic memberBuffer<TSource, TBufferOpening, TBufferClosing>(IQbservable<TSource>, IObservable<TBufferOpening>, Expression<Func<TBufferOpening, IObservable<TBufferClosing>>>)Indicates each element of a queryable observable sequence into consecutive non-overlapping buffers.
Public methodStatic memberCast<TResult>Converts the elements of an observable sequence to the specified type.
Public methodStatic memberCatch<TSource>(IQbservable<TSource>, IObservable<TSource>)Continues a queryable observable sequence that is terminated by an exception with the next queryable observable sequence.
Public methodStatic memberCatch<TSource>(IQbservableProvider, IEnumerable<IObservable<TSource>>)Continues a queryable observable sequence that is terminated by an exception with the next queryableobservable sequence.
Public methodStatic memberCatch<TSource>(IQbservableProvider, IObservable<TSource>[])Continues a queryable observable sequence that is terminated by an exception with the next queryable observable sequence.
Public methodStatic memberCatch<TSource, TException>(IQbservable<TSource>, Expression<Func<TException, IObservable<TSource>>>)Continues a queryable observable sequence that is terminated by an exception of the specified type with the queryable observable sequence produced by the handler.
Public methodStatic memberCombineLatest<TFirst, TSecond, TResult>Merges two queryable observable sequences into one queryable observable sequence by using the selector function whenever one of the queryable observable sequences produces an element.
Public methodStatic memberConcat<TSource>(IQbservable<IObservable<TSource>>)Concatenates an enumerable sequence of queryable observable sequences.
Public methodStatic memberConcat<TSource>(IQbservable<TSource>, IObservable<TSource>)Concatenates two observable sequences.
Public methodStatic memberConcat<TSource>(IQbservableProvider, IEnumerable<IObservable<TSource>>)Concatenates all the queryable observable sequences.
Public methodStatic memberConcat<TSource>(IQbservableProvider, IObservable<TSource>[])Concatenates a queryable observable sequence of queryable observable sequences.
Public methodStatic memberContains<TSource>(IQbservable<TSource>, TSource)Determines whether a queryable observable sequence contains a specified element by using the default equality comparer.
Public methodStatic memberContains<TSource>(IQbservable<TSource>, TSource, IEqualityComparer<TSource>)Determines whether an observable sequence contains a specified element by using a specified source type, source, value and comparer.
Public methodStatic memberCount<TSource>Returns a [System.Int32] that represents the total number of elements in a queryable observable sequence.
Public methodStatic memberCreate<TSource>(IQbservableProvider, Expression<Func<IObserver<TSource>, Action>>)Creates a queryable observable sequence from a specified subscribe method implementation with a specified subscribe.
Public methodStatic memberCreate<TSource>(IQbservableProvider, Expression<Func<IObserver<TSource>, IDisposable>>)Creates a queryable observable sequence from a specified subscribe method implementation with a specified subscribe.
Public methodStatic memberDefaultIfEmpty<TSource>(IQbservable<TSource>)Returns the elements of the specified sequence or the type parameter's default value in a singleton sequence if the sequence is empty.
Public methodStatic memberDefaultIfEmpty<TSource>(IQbservable<TSource>, TSource)Returns the elements of the specified sequence or the type parameter's default value in a singleton sequence if the sequence is empty.
Public methodStatic memberDefer<TValue>Returns a queryable observable sequence that invokes the observable factory whenever a new observer subscribes.
Public methodStatic memberDelay<TSource>(IQbservable<TSource>, DateTimeOffset)Indicates the queryable observable sequence by due time with the specified source and dueTime.
Public methodStatic memberDelay<TSource>(IQbservable<TSource>, TimeSpan)Indicates the queryable observable sequence by due time with the specified source and dueTime.
Public methodStatic memberDelay<TSource>(IQbservable<TSource>, DateTimeOffset, IScheduler)Indicates the queryable observable sequence by due time with the specified source, dueTime and scheduler.
Public methodStatic memberDelay<TSource>(IQbservable<TSource>, TimeSpan, IScheduler)Indicates the queryable observable sequence by due time with the specified source, dueTime and scheduler.
Public methodStatic memberDematerialize<TSource>Dematerializes the explicit notification values of a queryable observable sequence as implicit notifications.
Public methodStatic memberDistinct<TSource>(IQbservable<TSource>)Returns a queryable observable sequence that contains only distinct elements with a specified source.
Public methodStatic memberDistinct<TSource>(IQbservable<TSource>, IEqualityComparer<TSource>)Returns a queryable observable sequence that contains only distinct elements according to the comparer.
Public methodStatic memberDistinct<TSource, TKey>(IQbservable<TSource>, Expression<Func<TSource, TKey>>)Returns a queryable observable sequence that contains only distinct elements according to the keySelector.
Public methodStatic memberDistinct<TSource, TKey>(IQbservable<TSource>, Expression<Func<TSource, TKey>>, IEqualityComparer<TKey>)Returns a queryable observable sequence that contains only distinct elements according to the keySelector and comparer.
Public methodStatic memberDistinctUntilChanged<TSource>(IQbservable<TSource>)Returns a queryable observable sequence that contains only distinct contiguous elements with a specified source.
Public methodStatic memberDistinctUntilChanged<TSource>(IQbservable<TSource>, IEqualityComparer<TSource>)Returns a queryable observable sequence that contains only distinct contiguous elements according to the comparer.
Public methodStatic memberDistinctUntilChanged<TSource, TKey>(IQbservable<TSource>, Expression<Func<TSource, TKey>>)Returns a queryable observable sequence that contains only distinct contiguous elements according to the keySelector.
Public methodStatic memberDistinctUntilChanged<TSource, TKey>(IQbservable<TSource>, Expression<Func<TSource, TKey>>, IEqualityComparer<TKey>)Returns a queryable observable sequence that contains only distinct contiguous elements according to the keySelector and the comparer.
Public methodStatic memberDo<TSource>(IQbservable<TSource>, IObserver<TSource>)Invokes an action for each element in the queryable observable sequence.
Public methodStatic memberDo<TSource>(IQbservable<TSource>, Expression<Action<TSource>>)Invokes an action for each element in the queryable observable sequence and invokes an action upon graceful termination of the queryable observable sequence.
Public methodStatic memberDo<TSource>(IQbservable<TSource>, Expression<Action<TSource>>, Expression<Action<Exception>>)Invokes an action for each element in the queryable observable sequence and invokes an action upon exceptional termination of the queryable observable sequence.
Public methodStatic memberDo<TSource>(IQbservable<TSource>, Expression<Action<TSource>>, Expression<Action>)Invokes an action for each element in the queryable observable sequence, and invokes an action upon graceful or exceptional termination of the queryable observable sequence.
Public methodStatic memberDo<TSource>(IQbservable<TSource>, Expression<Action<TSource>>, Expression<Action<Exception>>, Expression<Action>)Invokes an action for each element in the queryable observable sequence, and invokes an action upon graceful or exceptional termination of the queryable observable sequence.
Public methodStatic memberElementAt<TSource>Returns the element at a specified index in a sequence.
Public methodStatic memberElementAtOrDefault<TSource>Returns the element at a specified index in a sequence or a default value if the index is out of range.
Public methodStatic memberEmpty<TResult>(IQbservableProvider)Returns an empty queryable observable sequence with the specified provider.
Public methodStatic memberEmpty<TResult>(IQbservableProvider, IScheduler)Returns an empty queryable observable sequence with the specified scheduler and provider.
Public methodStatic memberFinally<TSource>Invokes a specified action after source observable sequence terminates normally or by an exception.
Public methodStatic memberFromAsyncPattern(IQbservableProvider, Expression<Func<AsyncCallback, Object, IAsyncResult>>, Expression<Action<IAsyncResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<TResult>(IQbservableProvider, Expression<Func<AsyncCallback, Object, IAsyncResult>>, Expression<Func<IAsyncResult, TResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1>(IQbservableProvider, Expression<Func<T1, AsyncCallback, Object, IAsyncResult>>, Expression<Action<IAsyncResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, AsyncCallback, Object, IAsyncResult>>, Expression<Func<IAsyncResult, TResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, AsyncCallback, Object, IAsyncResult>>, Expression<Action<IAsyncResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, AsyncCallback, Object, IAsyncResult>>, Expression<Func<IAsyncResult, TResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, AsyncCallback, Object, IAsyncResult>>, Expression<Action<IAsyncResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, AsyncCallback, Object, IAsyncResult>>, Expression<Func<IAsyncResult, TResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, AsyncCallback, Object, IAsyncResult>>, Expression<Action<IAsyncResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, AsyncCallback, Object, IAsyncResult>>, Expression<Func<IAsyncResult, TResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, AsyncCallback, Object, IAsyncResult>>, Expression<Action<IAsyncResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, AsyncCallback, Object, IAsyncResult>>, Expression<Func<IAsyncResult, TResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, AsyncCallback, Object, IAsyncResult>>, Expression<Action<IAsyncResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, AsyncCallback, Object, IAsyncResult>>, Expression<Func<IAsyncResult, TResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, TResult>(IQbservableProvider, Expression<Func<T1, AsyncCallback, Object, IAsyncResult>>, Expression<Func<IAsyncResult, TResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, T2>(IQbservableProvider, Expression<Func<T1, T2, AsyncCallback, Object, IAsyncResult>>, Expression<Action<IAsyncResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, T2, TResult>(IQbservableProvider, Expression<Func<T1, T2, AsyncCallback, Object, IAsyncResult>>, Expression<Func<IAsyncResult, TResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, T2, T3>(IQbservableProvider, Expression<Func<T1, T2, T3, AsyncCallback, Object, IAsyncResult>>, Expression<Action<IAsyncResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, T2, T3, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, AsyncCallback, Object, IAsyncResult>>, Expression<Func<IAsyncResult, TResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, T2, T3, T4>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, AsyncCallback, Object, IAsyncResult>>, Expression<Action<IAsyncResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, T2, T3, T4, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, AsyncCallback, Object, IAsyncResult>>, Expression<Func<IAsyncResult, TResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, T2, T3, T4, T5>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, AsyncCallback, Object, IAsyncResult>>, Expression<Action<IAsyncResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, T2, T3, T4, T5, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, AsyncCallback, Object, IAsyncResult>>, Expression<Func<IAsyncResult, TResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, T2, T3, T4, T5, T6>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, AsyncCallback, Object, IAsyncResult>>, Expression<Action<IAsyncResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, T2, T3, T4, T5, T6, T7>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, AsyncCallback, Object, IAsyncResult>>, Expression<Action<IAsyncResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, T2, T3, T4, T5, T6, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, AsyncCallback, Object, IAsyncResult>>, Expression<Func<IAsyncResult, TResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, AsyncCallback, Object, IAsyncResult>>, Expression<Func<IAsyncResult, TResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, AsyncCallback, Object, IAsyncResult>>, Expression<Action<IAsyncResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, AsyncCallback, Object, IAsyncResult>>, Expression<Func<IAsyncResult, TResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromAsyncPattern<T1, T2, T3, T4, T5, T6, T7, T8, T9>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, AsyncCallback, Object, IAsyncResult>>, Expression<Action<IAsyncResult>>)Converts a Begin/End invoke function pair into an asynchronous function.
Public methodStatic memberFromEvent(IQbservableProvider, Expression<Action<Action>>, Expression<Action<Action>>)Converts a .NET event to a queryable observable sequence.
Public methodStatic memberFromEvent<TEventArgs>(IQbservableProvider, Expression<Action<Action<TEventArgs>>>, Expression<Action<Action<TEventArgs>>>)Converts a .NET event to a queryable observable sequence.
Public methodStatic memberFromEvent<TDelegate, TEventArgs>(IQbservableProvider, Expression<Action<TDelegate>>, Expression<Action<TDelegate>>)Converts a .NET event to a queryable observable sequence.
Public methodStatic memberFromEvent<TDelegate, TEventArgs>(IQbservableProvider, Expression<Func<Action<TEventArgs>, TDelegate>>, Expression<Action<TDelegate>>, Expression<Action<TDelegate>>)Converts a .NET event to a queryable observable sequence.
Public methodStatic memberFromEventPattern(IQbservableProvider, Expression<Action<EventHandler>>, Expression<Action<EventHandler>>)Converts a .NET event, conforming to the standard .NET event pattern, to a queryable observable sequence with a specified add handler and remove handler.
Public methodStatic memberFromEventPattern(IQbservableProvider, Object, String)Converts a .NET event, conforming to the standard .NET event pattern, to an queryable observable sequence, using reflection to find an instance event.
Public methodStatic memberFromEventPattern(IQbservableProvider, Type, String)Converts a .NET event, conforming to the standard .NET event pattern, to an queryable observable sequence, using reflection to find a static event.
Public methodStatic memberFromEventPattern<TEventArgs>(IQbservableProvider, Expression<Action<EventHandler<TEventArgs>>>, Expression<Action<EventHandler<TEventArgs>>>)Converts a .NET event, conforming to the standard .NET event pattern, to an queryable observable sequence with the specified add handler and remove handler.
Public methodStatic memberFromEventPattern<TEventArgs>(IQbservableProvider, Object, String)Converts a .NET event, conforming to the standard .NET event pattern, to an observable sequence, using reflection to find an instance event.
Public methodStatic memberFromEventPattern<TEventArgs>(IQbservableProvider, Type, String)Converts a .NET event, conforming to the standard .NET event pattern, to a queryable observable sequence, using reflection to find a static event.
Public methodStatic memberFromEventPattern<TDelegate, TEventArgs>(IQbservableProvider, Expression<Action<TDelegate>>, Expression<Action<TDelegate>>)Converts a .NET event, conforming to the standard .NET event pattern, to an queryable observable sequence with the specified add handler and remove handler.
Public methodStatic memberFromEventPattern<TDelegate, TEventArgs>(IQbservableProvider, Expression<Func<EventHandler<TEventArgs>, TDelegate>>, Expression<Action<TDelegate>>, Expression<Action<TDelegate>>)Converts a .NET event, conforming to the standard .NET event pattern, to an queryable observable sequence with the specified conversion, add handler and remove handler.
Public methodStatic memberGenerate<TState, TResult>(IQbservableProvider, TState, Expression<Func<TState, Boolean>>, Expression<Func<TState, TState>>, Expression<Func<TState, TResult>>)Generates a queryable observable sequence by iterating a state from an initial state until the condition fails.
Public methodStatic memberGenerate<TState, TResult>(IQbservableProvider, TState, Expression<Func<TState, Boolean>>, Expression<Func<TState, TState>>, Expression<Func<TState, TResult>>, Expression<Func<TState, DateTimeOffset>>)Generates a queryable observable sequence by iterating a state from an initial state until the condition fails.
Public methodStatic memberGenerate<TState, TResult>(IQbservableProvider, TState, Expression<Func<TState, Boolean>>, Expression<Func<TState, TState>>, Expression<Func<TState, TResult>>, Expression<Func<TState, TimeSpan>>)Generates a queryable observable sequence by iterating a state from an initial state until the condition fails.
Public methodStatic memberGenerate<TState, TResult>(IQbservableProvider, TState, Expression<Func<TState, Boolean>>, Expression<Func<TState, TState>>, Expression<Func<TState, TResult>>, IScheduler)Generates a queryable observable sequence by iterating a state from an initial state until the condition fails.
Public methodStatic memberGenerate<TState, TResult>(IQbservableProvider, TState, Expression<Func<TState, Boolean>>, Expression<Func<TState, TState>>, Expression<Func<TState, TResult>>, Expression<Func<TState, DateTimeOffset>>, IScheduler)Generates a queryable observable sequence by iterating a state from an initial state until the condition fails.
Public methodStatic memberGenerate<TState, TResult>(IQbservableProvider, TState, Expression<Func<TState, Boolean>>, Expression<Func<TState, TState>>, Expression<Func<TState, TResult>>, Expression<Func<TState, TimeSpan>>, IScheduler)Generates a queryable observable sequence by iterating a state from an initial state until the condition fails.
Public methodStatic memberGroupBy<TSource, TKey>(IQbservable<TSource>, Expression<Func<TSource, TKey>>)Groups the elements of a queryable observable sequence according to a specified key selector function.
Public methodStatic memberGroupBy<TSource, TKey>(IQbservable<TSource>, Expression<Func<TSource, TKey>>, IEqualityComparer<TKey>)Groups the elements of a queryable observable sequence according to a specified key selector function and comparer.
Public methodStatic memberGroupBy<TSource, TKey, TElement>(IQbservable<TSource>, Expression<Func<TSource, TKey>>, Expression<Func<TSource, TElement>>)Groups the elements of a queryable observable sequence and selects the resulting elements by using a specified function.
Public methodStatic memberGroupBy<TSource, TKey, TElement>(IQbservable<TSource>, Expression<Func<TSource, TKey>>, Expression<Func<TSource, TElement>>, IEqualityComparer<TKey>)Groups the elements of a queryable observable sequence according to a specified key selector function and comparer and selects the resulting elements by using a specified function.
Public methodStatic memberGroupByUntil<TSource, TKey, TDuration>(IQbservable<TSource>, Expression<Func<TSource, TKey>>, Expression<Func<IGroupedObservable<TKey, TSource>, IObservable<TDuration>>>)Groups the elements of a queryable observable sequence according to a specified key selector function.
Public methodStatic memberGroupByUntil<TSource, TKey, TDuration>(IQbservable<TSource>, Expression<Func<TSource, TKey>>, Expression<Func<IGroupedObservable<TKey, TSource>, IObservable<TDuration>>>, IEqualityComparer<TKey>)Groups the elements of a queryable observable sequence according to a specified key selector function and comparer.
Public methodStatic memberGroupByUntil<TSource, TKey, TElement, TDuration>(IQbservable<TSource>, Expression<Func<TSource, TKey>>, Expression<Func<TSource, TElement>>, Expression<Func<IGroupedObservable<TKey, TElement>, IObservable<TDuration>>>)Groups the elements of a queryable observable sequence according to a specified key selector function and selects the resulting elements by using a specified function.
Public methodStatic memberGroupByUntil<TSource, TKey, TElement, TDuration>(IQbservable<TSource>, Expression<Func<TSource, TKey>>, Expression<Func<TSource, TElement>>, Expression<Func<IGroupedObservable<TKey, TElement>, IObservable<TDuration>>>, IEqualityComparer<TKey>)Groups the elements of a queryable observable sequence according to a specified key selector function and comparer and selects the resulting elements by using a specified function.
Public methodStatic memberGroupJoin<TLeft, TRight, TLeftDuration, TRightDuration, TResult>Correlates the elements of two sequences based on overlapping durations, and groups the results.
Public methodStatic memberIgnoreElements<TSource>Ignores all values in a queryable observable sequence leaving only the termination messages.
Public methodStatic memberInterval(IQbservableProvider, TimeSpan)Returns a queryable observable sequence that produces a value after each period.
Public methodStatic memberInterval(IQbservableProvider, TimeSpan, IScheduler)Returns a queryable observable sequence that produces a value after each period.
Public methodStatic memberJoin<TLeft, TRight, TLeftDuration, TRightDuration, TResult>Correlates the elements of two sequences based on overlapping durations.
Public methodStatic memberLatest<TSource>Samples the most recent value in a queryable observable sequence.
Public methodStatic memberLongCount<TSource>Returns a [System.Int64] that represents the total number of elements in a queryable observable sequence.
Public methodStatic memberMaterialize<TSource>Materializes the implicit notifications of a queryable observable sequence as explicit notification values.
Public methodStatic memberMax(IQbservable<Decimal>)Returns the maximum value in a queryable observable sequence of Decimal values.
Public methodStatic memberMax(IQbservable<Double>)Returns the maximum value in a queryable observable sequence of Double values.
Public methodStatic memberMax(IQbservable<Int32>)Returns the maximum value in a queryable observable sequence of Int32 values.
Public methodStatic memberMax(IQbservable<Int64>)Returns the maximum value in a queryable observable sequence of Int64 values.
Public methodStatic memberMax(IQbservable<Nullable<Decimal>>)Returns the maximum value in a queryable observable sequence of nullable Decimal values.
Public methodStatic memberMax(IQbservable<Nullable<Double>>)Returns the maximum value in a queryable observable sequence of nullable Double values.
Public methodStatic memberMax(IQbservable<Nullable<Int32>>)Returns the maximum value in a queryable observable sequence of nullable Int32 values.
Public methodStatic memberMax(IQbservable<Nullable<Int64>>)Returns the maximum value in a queryable observable sequence of nullable Int64 values.
Public methodStatic memberMax(IQbservable<Nullable<Single>>)Returns the maximum value in a queryable observable sequence of nullable Float values.
Public methodStatic memberMax(IQbservable<Single>)Returns the maximum value in a queryable observable sequence of Float values.
Public methodStatic memberMax<TSource>(IQbservable<TSource>)Returns the maximum element in a queryable observable sequence.
Public methodStatic memberMax<TSource>(IQbservable<TSource>, IComparer<TSource>)Returns the maximum value in a queryable observable sequence according to the specified comparer.
Public methodStatic memberMaxBy<TSource, TKey>(IQbservable<TSource>, Expression<Func<TSource, TKey>>)Returns the elements in a queryable observable sequence with the maximum key value.
Public methodStatic memberMaxBy<TSource, TKey>(IQbservable<TSource>, Expression<Func<TSource, TKey>>, IComparer<TKey>)Returns the elements in a queryable observable sequence with the maximum key value.
Public methodStatic memberMerge<TSource>(IQbservable<IObservable<TSource>>)Merges all the queryable observable sequences into a single queryable observable sequence.
Public methodStatic memberMerge<TSource>(IQbservable<IObservable<TSource>>, Int32)Merges an enumerable sequence of queryable observable sequences into a queryable observable sequence, limiting the number of concurrent subscriptions to inner sequences.
Public methodStatic memberMerge<TSource>(IQbservable<TSource>, IObservable<TSource>)Merges an enumerable sequence of queryable observable sequences into a single observable sequence.
Public methodStatic memberMerge<TSource>(IQbservableProvider, IEnumerable<IObservable<TSource>>)Merges an enumerable sequence of queryable observable sequences into a single queryable observable sequence.
Public methodStatic memberMerge<TSource>(IQbservableProvider, IObservable<TSource>[])Merges all the queryable observable sequences into a single queryable observable sequence.
Public methodStatic memberMerge<TSource>(IQbservable<TSource>, IObservable<TSource>, IScheduler)Merges two queryable observable sequences into a single queryable observable sequence.
Public methodStatic memberMerge<TSource>(IQbservableProvider, IEnumerable<IObservable<TSource>>, Int32)Merges an enumerable sequence of queryable observable sequences into an queryable observable sequence, limiting the number of concurrent subscriptions to inner sequences.
Public methodStatic memberMerge<TSource>(IQbservableProvider, IEnumerable<IObservable<TSource>>, IScheduler)Merges an enumerable sequence of queryable observable sequences into a single queryable observable sequence.
Public methodStatic memberMerge<TSource>(IQbservableProvider, IScheduler, IObservable<TSource>[])Merges all the queryable observable sequences into a single queryable observable sequence.
Public methodStatic memberMerge<TSource>(IQbservableProvider, IEnumerable<IObservable<TSource>>, Int32, IScheduler)Merges an enumerable sequence of queryable observable sequences into an queryable observable sequence, limiting the number of concurrent subscriptions to inner sequences.
Public methodStatic memberMin(IQbservable<Decimal>)Returns the minimum value in a queryable observable sequence of Decimal values.
Public methodStatic memberMin(IQbservable<Double>)Returns the minimum value in a queryable observable sequence of Double values.
Public methodStatic memberMin(IQbservable<Int32>)Returns the minimum value in a queryable observable sequence of Int32 values.
Public methodStatic memberMin(IQbservable<Int64>)Returns the minimum value in a queryable observable sequence of Int64 values.
Public methodStatic memberMin(IQbservable<Nullable<Decimal>>)Returns the minimum value in a queryable observable sequence of nullable Decimal values.
Public methodStatic memberMin(IQbservable<Nullable<Double>>)Returns the minimum value in a queryable observable sequence of nullable Double values.
Public methodStatic memberMin(IQbservable<Nullable<Int32>>)Returns the minimum value in a queryable observable sequence of nullable Int32 values.
Public methodStatic memberMin(IQbservable<Nullable<Int64>>)Returns the minimum value in a queryable observable sequence of nullable Int64 values.
Public methodStatic memberMin(IQbservable<Nullable<Single>>)Returns the minimum value in a queryable observable sequence of nullable Float values.
Public methodStatic memberMin(IQbservable<Single>)Returns the minimum value in a queryable observable sequence of Float values.
Public methodStatic memberMin<TSource>(IQbservable<TSource>)Returns the minimum element in a queryable observable sequence.
Public methodStatic memberMin<TSource>(IQbservable<TSource>, IComparer<TSource>)Returns the minimum value in a queryable observable sequence according to the specified comparer.
Public methodStatic memberMinBy<TSource, TKey>(IQbservable<TSource>, Expression<Func<TSource, TKey>>)Returns the elements in a queryable observable sequence with the minimum key value.
Public methodStatic memberMinBy<TSource, TKey>(IQbservable<TSource>, Expression<Func<TSource, TKey>>, IComparer<TKey>)Returns the elements in a queryable observable sequence with the minimum key value according to the specified comparer.
Public methodStatic memberMostRecent<TSource>Samples the most recent value in a queryable observable sequence.
Public methodStatic memberMulticast<TSource, TIntermediate, TResult>Returns a queryable observable sequence that contains the elements of a sequence produced by multicasting the source sequence within a selector function.
Public methodStatic memberNever<TResult>Returns a non-terminating queryable observable sequence.
Public methodStatic memberNext<TSource>Samples the next value (blocking without buffering) from in an queryable observable sequence.
Public methodStatic memberObserveOn<TSource>(IQbservable<TSource>, IScheduler)Asynchronously notify observers on the specified synchronization context.
Public methodStatic memberObserveOn<TSource>(IQbservable<TSource>, SynchronizationContext)Asynchronously notify observers on the specified synchronization context.
Public methodStatic memberOfType<TResult>Filters the elements of a queryable observable sequence based on the specified type.
Public methodStatic memberOnErrorResumeNext<TSource>(IQbservable<TSource>, IObservable<TSource>)Continues a queryable observable sequence that is terminated normally or by an exception with the next queryable observable sequence.
Public methodStatic memberOnErrorResumeNext<TSource>(IQbservableProvider, IEnumerable<IObservable<TSource>>)Continues a queryable observable sequence that is terminated normally or by an exception with the next queryable observable sequence.
Public methodStatic memberOnErrorResumeNext<TSource>(IQbservableProvider, IObservable<TSource>[])Continues a queryable observable sequence that is terminated normally or by an exception with the next queryable observable sequence.
Public methodStatic memberPublish<TSource, TResult>(IQbservable<TSource>, Expression<Func<IObservable<TSource>, IObservable<TResult>>>)Returns a queryable observable sequence that is the result of invoking the selector on a connectable queryable observable sequence that shares a single subscription to the underlying sequence.
Public methodStatic memberPublish<TSource, TResult>(IQbservable<TSource>, Expression<Func<IObservable<TSource>, IObservable<TResult>>>, TSource)Returns a queryable observable sequence that is the result of invoking the selector on a connectable observable sequence that shares a single subscription to the underlying sequence.
Public methodStatic memberPublishLast<TSource, TResult>Returns a queryable observable sequence that is the result of invoking the selector on a connectable queryable observable sequence that shares a single subscription to the underlying sequence containing only the last notification.
Public methodStatic memberRange(IQbservableProvider, Int32, Int32)Generates a queryable observable sequence of integral numbers within a specified range.
Public methodStatic memberRange(IQbservableProvider, Int32, Int32, IScheduler)Generates a queryable observable sequence of integral numbers within a specified range.
Public methodStatic memberRefCount<TSource>Returns a queryable observable sequence that stays connected to the source as long as there is at least one subscription to the queryable observable sequence.
Public methodStatic memberRepeat<TSource>(IQbservable<TSource>)Repeats the queryable observable sequence indefinitely.
Public methodStatic memberRepeat<TSource>(IQbservable<TSource>, Int32)Repeats the queryable observable sequence indefinitely.
Public methodStatic memberRepeat<TResult>(IQbservableProvider, TResult)Generates a queryable observable sequence that repeats the given element infinitely.
Public methodStatic memberRepeat<TResult>(IQbservableProvider, TResult, Int32)Generates a queryable observable sequence that repeats the given element the specified number of times.
Public methodStatic memberRepeat<TResult>(IQbservableProvider, TResult, IScheduler)Generates a queryable observable sequence that repeats the given element infinitely.
Public methodStatic memberRepeat<TResult>(IQbservableProvider, TResult, Int32, IScheduler)Generates a queryable observable sequence that repeats the given element of the specified number of times.
Public methodStatic memberReplay<TSource, TResult>(IQbservable<TSource>, Expression<Func<IObservable<TSource>, IObservable<TResult>>>)Returns a queryable observable sequence that is the result of invoking the selector on a connectable observable sequence that shares a single subscription to the underlying sequence and starts with initial value.
Public methodStatic memberReplay<TSource, TResult>(IQbservable<TSource>, Expression<Func<IObservable<TSource>, IObservable<TResult>>>, Int32)Returns a queryable observable sequence that is the result of invoking the selector on a connectable queryable observable sequence that shares a single subscription to the underlying sequence replaying bufferSize notifications.
Public methodStatic memberReplay<TSource, TResult>(IQbservable<TSource>, Expression<Func<IObservable<TSource>, IObservable<TResult>>>, IScheduler)Returns a queryable observable sequence that is the result of invoking the selector on a connectable queryable observable sequence that shares a single subscription to the underlying sequence replaying all notifications.
Public methodStatic memberReplay<TSource, TResult>(IQbservable<TSource>, Expression<Func<IObservable<TSource>, IObservable<TResult>>>, TimeSpan)Returns a queryable observable sequence that is the result of invoking the selector on a connectable queryable observable sequence that shares a single subscription to the underlying sequence replaying all notifications within window.
Public methodStatic memberReplay<TSource, TResult>(IQbservable<TSource>, Expression<Func<IObservable<TSource>, IObservable<TResult>>>, Int32, IScheduler)Returns a queryable observable sequence that is the result of invoking the selector on a connectable queryable observable sequence that shares a single subscription to the underlying sequence replaying bufferSize notifications.
Public methodStatic memberReplay<TSource, TResult>(IQbservable<TSource>, Expression<Func<IObservable<TSource>, IObservable<TResult>>>, Int32, TimeSpan)Returns a queryable observable sequence that is the result of invoking the selector on a connectable queryable observable sequence that shares a single subscription to the underlying sequence replaying bufferSize notifications within window.
Public methodStatic memberReplay<TSource, TResult>(IQbservable<TSource>, Expression<Func<IObservable<TSource>, IObservable<TResult>>>, TimeSpan, IScheduler)Returns a queryable observable sequence that is the result of invoking the selector on a connectable queryable observable sequence that shares a single subscription to the underlying sequence replaying all notifications within window.
Public methodStatic memberReplay<TSource, TResult>(IQbservable<TSource>, Expression<Func<IObservable<TSource>, IObservable<TResult>>>, Int32, TimeSpan, IScheduler)Returns a queryable observable sequence that is the result of invoking the selector on a connectable queryable observable sequence that shares a single subscription to the underlying sequence replaying bufferSize notifications within window.
Public methodStatic memberRetry<TSource>(IQbservable<TSource>)Repeats the source queryable observable sequence until it successfully terminates.
Public methodStatic memberRetry<TSource>(IQbservable<TSource>, Int32)Repeats the source queryable observable sequence until it successfully terminates.
Public methodStatic memberReturn<TResult>(IQbservableProvider, TResult)Returns a queryable observable sequence that contains a single element with a specified value.
Public methodStatic memberReturn<TResult>(IQbservableProvider, TResult, IScheduler)Returns a queryable observable sequence that contains a single value with a specified value and scheduler.
Public methodStatic memberSample<TSource>(IQbservable<TSource>, TimeSpan)Samples the queryable observable sequence at each interval.
Public methodStatic memberSample<TSource>(IQbservable<TSource>, TimeSpan, IScheduler)Samples the queryable observable sequence at each interval with the specified source, interval and scheduler.
Public methodStatic memberSample<TSource, TSample>(IQbservable<TSource>, IObservable<TSample>)Samples the queryable observable sequence at sampling ticks with the specified source and sampler.
Public methodStatic memberScan<TSource>(IQbservable<TSource>, Expression<Func<TSource, TSource, TSource>>)Applies an accumulator function over a queryable observable sequence and returns each intermediate result with the specified source and accumulator.
Public methodStatic memberScan<TSource, TAccumulate>(IQbservable<TSource>, TAccumulate, Expression<Func<TAccumulate, TSource, TAccumulate>>)Applies an accumulator function over a queryable observable sequence and returns each intermediate result with the specified source, seed and accumulator.
Public methodStatic memberSelect<TSource, TResult>(IQbservable<TSource>, Expression<Func<TSource, TResult>>)Projects each element of a queryable observable sequence into a new form with the specified source and selector.
Public methodStatic memberSelect<TSource, TResult>(IQbservable<TSource>, Expression<Func<TSource, Int32, TResult>>)Projects each element of a queryable observable sequence into a new form by incorporating the element’s index with the specified source and selector.
Public methodStatic memberSelectMany<TSource, TOther>(IQbservable<TSource>, IObservable<TOther>)Projects each element of a queryable observable sequence to a queryable observable sequence and flattens the resulting queryable observable sequences into one queryable observable sequence.
Public methodStatic memberSelectMany<TSource, TResult>(IQbservable<TSource>, Expression<Func<TSource, IEnumerable<TResult>>>)Projects each element of a queryable observable sequence to a queryable observable sequence and flattens the resulting queryable observable sequences into one queryable observable sequence.
Public methodStatic memberSelectMany<TSource, TResult>(IQbservable<TSource>, Expression<Func<TSource, IObservable<TResult>>>)Projects each element of a queryable observable sequence to a queryable observable sequence and flattens the resulting queryable observable sequences into one queryable observable sequence.
Public methodStatic memberSelectMany<TSource, TResult>(IQbservable<TSource>, Expression<Func<TSource, IObservable<TResult>>>, Expression<Func<Exception, IObservable<TResult>>>, Expression<Func<IObservable<TResult>>>)Projects each element of a queryable observable sequence to a queryable observable sequence and flattens the resulting queryable observable sequences into one queryable observable sequence.
Public methodStatic memberSelectMany<TSource, TCollection, TResult>(IQbservable<TSource>, Expression<Func<TSource, IEnumerable<TCollection>>>, Expression<Func<TSource, TCollection, TResult>>)Projects each element of a queryable observable sequence to a queryable observable sequence and flattens the resulting queryable observable sequences into one queryable observable sequence.
Public methodStatic memberSelectMany<TSource, TCollection, TResult>(IQbservable<TSource>, Expression<Func<TSource, IObservable<TCollection>>>, Expression<Func<TSource, TCollection, TResult>>)Projects each element of a queryable observable sequence to a queryable observable sequence and flattens the resulting queryable observable sequences into one queryable observable sequence.
Public methodStatic memberSequenceEqual<TSource>(IQbservable<TSource>, IObservable<TSource>)Determines whether two sequences are equal by comparing the elements pairwise.
Public methodStatic memberSequenceEqual<TSource>(IQbservable<TSource>, IObservable<TSource>, IEqualityComparer<TSource>)Determines whether two sequences are equal by comparing the elements pairwise using a specified equality comparer.
Public methodStatic memberSkip<TSource>Bypasses a specified number of values in an observable sequence and then returns the remaining values.
Public methodStatic memberSkipLast<TSource>Bypasses a specified number of elements at the end of a queryable observable sequence.
Public methodStatic memberSkipUntil<TSource, TOther>Returns the values from the source queryable observable sequence only after the other queryable observable sequence produces a value.
Public methodStatic memberSkipWhile<TSource>(IQbservable<TSource>, Expression<Func<TSource, Boolean>>)Bypasses values in a queryable observable sequence as long as a specified condition is true and then returns the remaining values.
Public methodStatic memberSkipWhile<TSource>(IQbservable<TSource>, Expression<Func<TSource, Int32, Boolean>>)Bypasses values in a queryable observable sequence as long as a specified condition is true and then returns the remaining values.
Public methodStatic memberStart(IQbservableProvider, Expression<Action>)Invokes the action asynchronously.
Public methodStatic memberStart(IQbservableProvider, Expression<Action>, IScheduler)Invokes the action asynchronously.
Public methodStatic memberStart<TSource>(IQbservableProvider, Expression<Func<TSource>>)Invokes the function asynchronously.
Public methodStatic memberStart<TSource>(IQbservableProvider, Expression<Func<TSource>>, IScheduler)Invokes the function asynchronously.
Public methodStatic memberStartWith<TSource>(IQbservable<TSource>, TSource[])Prepends a sequence of values to a queryable observable sequence with the specified source and values.
Public methodStatic memberStartWith<TSource>(IQbservable<TSource>, IScheduler, TSource[])Prepends a sequence of values to a queryable observable sequence with the specified source, scheduler and values.
Public methodStatic memberSubscribeOn<TSource>(IQbservable<TSource>, IScheduler)Asynchronously subscribes and unsubscribes observers on the specified synchronization context.
Public methodStatic memberSubscribeOn<TSource>(IQbservable<TSource>, SynchronizationContext)Asynchronously subscribes and unsubscribes observers on the specified synchronization context.
Public methodStatic memberSum(IQbservable<Decimal>)Computes the sum of a sequence of Decimal values.
Public methodStatic memberSum(IQbservable<Double>)Computes the sum of a sequence of Double values.
Public methodStatic memberSum(IQbservable<Int32>)Computes the sum of a sequence of Int32 values.
Public methodStatic memberSum(IQbservable<Int64>)Computes the sum of a sequence of Int64 values.
Public methodStatic memberSum(IQbservable<Nullable<Decimal>>)Computes the sum of a sequence of nullable Decimal values.
Public methodStatic memberSum(IQbservable<Nullable<Double>>)Computes the sum of a sequence of nullable Double values.
Public methodStatic memberSum(IQbservable<Nullable<Int32>>)Computes the sum of a sequence of nullable Int32 values.
Public methodStatic memberSum(IQbservable<Nullable<Int64>>)Computes the sum of a sequence of nullable Int64 values.
Public methodStatic memberSum(IQbservable<Nullable<Single>>)Computes the sum of a sequence of nullable Float values.
Public methodStatic memberSum(IQbservable<Single>)Computes the sum of a sequence of Float values.
Public methodStatic memberSwitch<TSource>Transforms a queryable observable sequence of queryable observable sequences into a queryable observable sequence producing values only from the most recent queryable observable sequence.
Public methodStatic memberSynchronize<TSource>(IQbservable<TSource>)Synchronizes the queryable observable sequence.
Public methodStatic memberSynchronize<TSource>(IQbservable<TSource>, Object)Synchronizes the queryable observable sequence.
Public methodStatic memberTake<TSource>Returns a specified number of contiguous values from the start of a queryable observable sequence.
Public methodStatic memberTakeLast<TSource>Returns a specified number of contiguous elements from the end of a queryable observable sequence.
Public methodStatic memberTakeUntil<TSource, TOther>Returns the values from the source queryable observable sequence until the other queryable observable sequence produces a value.
Public methodStatic memberTakeWhile<TSource>(IQbservable<TSource>, Expression<Func<TSource, Boolean>>)Returns values from a queryable observable sequence as long as a specified condition is true, and then skips the remaining values.
Public methodStatic memberTakeWhile<TSource>(IQbservable<TSource>, Expression<Func<TSource, Int32, Boolean>>)Returns values from a queryable observable sequence as long as a specified condition is true, and then skips the remaining values.
Public methodStatic memberThen<TSource, TResult>Matches when the queryable observable sequence has an available value and projects the value.
Public methodStatic memberThrottle<TSource>(IQbservable<TSource>, TimeSpan)Ignores the values from a queryable observable sequence which are followed by another value before due time with the specified source and dueTime.
Public methodStatic memberThrottle<TSource>(IQbservable<TSource>, TimeSpan, IScheduler)Ignores the values from a queryable observable sequence which are followed by another value before due time with the specified source, dueTime and scheduler.
Public methodStatic memberThrow<TResult>(IQbservableProvider, Exception)Returns a queryable observable sequence that terminates with an exception.
Public methodStatic memberThrow<TResult>(IQbservableProvider, Exception, IScheduler)Returns a queryable observable sequence that terminates with an exception with the specified scheduler.
Public methodStatic memberTimeInterval<TSource>(IQbservable<TSource>)Records the time interval between consecutive values in a queryable observable sequence with the specified source.
Public methodStatic memberTimeInterval<TSource>(IQbservable<TSource>, IScheduler)Records the time interval between consecutive values in a queryable observable sequence with the specified source and scheduler.
Public methodStatic memberTimeout<TSource>(IQbservable<TSource>, DateTimeOffset)Returns either the queryable observable sequence or a TimeoutException if dueTime elapses.
Public methodStatic memberTimeout<TSource>(IQbservable<TSource>, TimeSpan)Returns either the queryable observable sequence or a TimeoutException if dueTime elapses.
Public methodStatic memberTimeout<TSource>(IQbservable<TSource>, DateTimeOffset, IObservable<TSource>)Returns either the queryable observable sequence or an TimeoutException if dueTime elapses.
Public methodStatic memberTimeout<TSource>(IQbservable<TSource>, DateTimeOffset, IScheduler)Returns either the queryable observable sequence or a TimeoutException if dueTime elapses.
Public methodStatic memberTimeout<TSource>(IQbservable<TSource>, TimeSpan, IObservable<TSource>)Returns the source queryable observable sequence or the other queryable observable sequence if dueTime elapses.
Public methodStatic memberTimeout<TSource>(IQbservable<TSource>, TimeSpan, IScheduler)Returns either the queryable observable sequence or a TimeoutException if dueTime elapses.
Public methodStatic memberTimeout<TSource>(IQbservable<TSource>, DateTimeOffset, IObservable<TSource>, IScheduler)Returns the source queryable observable sequence or the other queryable observable sequence if dueTime elapses.
Public methodStatic memberTimeout<TSource>(IQbservable<TSource>, TimeSpan, IObservable<TSource>, IScheduler)Returns the source queryable observable sequence or the other queryable observable sequence if dueTime elapses.
Public methodStatic memberTimer(IQbservableProvider, DateTimeOffset)Returns a queryable observable sequence that produces a value at due time.
Public methodStatic memberTimer(IQbservableProvider, TimeSpan)Returns a queryable observable sequence that produces a value after the due time has elapsed.
Public methodStatic memberTimer(IQbservableProvider, DateTimeOffset, IScheduler)Returns a queryable observable sequence that produces a value at due time.
Public methodStatic memberTimer(IQbservableProvider, DateTimeOffset, TimeSpan)Returns a queryable observable sequence that produces a value at due time and then after each period.
Public methodStatic memberTimer(IQbservableProvider, TimeSpan, IScheduler)Returns a queryable observable sequence that produces a value after the due time has elapsed.
Public methodStatic memberTimer(IQbservableProvider, TimeSpan, TimeSpan)Returns a queryable observable sequence that produces a value after due time has elapsed and then after each period.
Public methodStatic memberTimer(IQbservableProvider, DateTimeOffset, TimeSpan, IScheduler)Returns a queryable observable sequence that produces a value at due time and then after each period.
Public methodStatic memberTimer(IQbservableProvider, TimeSpan, TimeSpan, IScheduler)Returns a queryable observable sequence that produces a value after due time has elapsed and then each period.
Public methodStatic memberTimestamp<TSource>(IQbservable<TSource>)Records the timestamp for each value in a queryable observable sequence with the specified source.
Public methodStatic memberTimestamp<TSource>(IQbservable<TSource>, IScheduler)Records the timestamp for each value in a queryable observable sequence with the specified source and scheduler.
Public methodStatic memberToArray<TSource>Creates an array from a queryable observable sequence.
Public methodStatic memberToAsync(IQbservableProvider, Expression<Action>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync(IQbservableProvider, Expression<Action>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<TSource>(IQbservableProvider, Expression<Action<TSource>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<TResult>(IQbservableProvider, Expression<Func<TResult>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<TSource>(IQbservableProvider, Expression<Action<TSource>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<TResult>(IQbservableProvider, Expression<Func<TResult>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10>(IQbservableProvider, Expression<Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10>(IQbservableProvider, Expression<Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, TResult>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11>(IQbservableProvider, Expression<Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11>(IQbservableProvider, Expression<Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, TResult>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12>(IQbservableProvider, Expression<Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12>(IQbservableProvider, Expression<Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, TResult>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13>(IQbservableProvider, Expression<Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13>(IQbservableProvider, Expression<Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, TResult>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14>(IQbservableProvider, Expression<Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14>(IQbservableProvider, Expression<Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, TResult>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15>(IQbservableProvider, Expression<Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15>(IQbservableProvider, Expression<Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, TResult>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16>(IQbservableProvider, Expression<Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TResult>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16>(IQbservableProvider, Expression<Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, TResult>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TResult>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, TResult>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2>(IQbservableProvider, Expression<Action<T1, T2>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<TSource, TResult>(IQbservableProvider, Expression<Func<TSource, TResult>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2>(IQbservableProvider, Expression<Action<T1, T2>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<TSource, TResult>(IQbservableProvider, Expression<Func<TSource, TResult>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3>(IQbservableProvider, Expression<Action<T1, T2, T3>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, TResult>(IQbservableProvider, Expression<Func<T1, T2, TResult>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3>(IQbservableProvider, Expression<Action<T1, T2, T3>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, TResult>(IQbservableProvider, Expression<Func<T1, T2, TResult>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4>(IQbservableProvider, Expression<Action<T1, T2, T3, T4>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, TResult>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4>(IQbservableProvider, Expression<Action<T1, T2, T3, T4>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, TResult>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5>(IQbservableProvider, Expression<Action<T1, T2, T3, T4, T5>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, TResult>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5>(IQbservableProvider, Expression<Action<T1, T2, T3, T4, T5>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, TResult>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6>(IQbservableProvider, Expression<Action<T1, T2, T3, T4, T5, T6>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, TResult>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6>(IQbservableProvider, Expression<Action<T1, T2, T3, T4, T5, T6>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, TResult>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7>(IQbservableProvider, Expression<Action<T1, T2, T3, T4, T5, T6, T7>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, TResult>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7>(IQbservableProvider, Expression<Action<T1, T2, T3, T4, T5, T6, T7>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, TResult>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8>(IQbservableProvider, Expression<Action<T1, T2, T3, T4, T5, T6, T7, T8>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, TResult>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8>(IQbservableProvider, Expression<Action<T1, T2, T3, T4, T5, T6, T7, T8>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, TResult>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9>(IQbservableProvider, Expression<Action<T1, T2, T3, T4, T5, T6, T7, T8, T9>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, TResult>>)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, T9>(IQbservableProvider, Expression<Action<T1, T2, T3, T4, T5, T6, T7, T8, T9>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToAsync<T1, T2, T3, T4, T5, T6, T7, T8, TResult>(IQbservableProvider, Expression<Func<T1, T2, T3, T4, T5, T6, T7, T8, TResult>>, IScheduler)Converts the function into an asynchronous function.
Public methodStatic memberToDictionary<TSource, TKey>(IQbservable<TSource>, Expression<Func<TSource, TKey>>)Creates a dictionary from a queryable observable sequence according to a specified key selector function.
Public methodStatic memberToDictionary<TSource, TKey>(IQbservable<TSource>, Expression<Func<TSource, TKey>>, IEqualityComparer<TKey>)Creates a dictionary from a queryable observable sequence according to a specified key selector function, and a comparer.
Public methodStatic memberToDictionary<TSource, TKey, TElement>(IQbservable<TSource>, Expression<Func<TSource, TKey>>, Expression<Func<TSource, TElement>>)Creates a dictionary from a queryable observable sequence according to a specified key selector function, and an element selector function.
Public methodStatic memberToDictionary<TSource, TKey, TElement>(IQbservable<TSource>, Expression<Func<TSource, TKey>>, Expression<Func<TSource, TElement>>, IEqualityComparer<TKey>)Creates a dictionary from a queryable observable sequence according to a specified key selector function, a comparer, and an element selector function.
Public methodStatic memberToList<TSource>Creates a list from a queryable observable sequence.
Public methodStatic memberToLookup<TSource, TKey>(IQbservable<TSource>, Expression<Func<TSource, TKey>>)Creates a lookup from a queryable observable sequence according to a specified key selector function.
Public methodStatic memberToLookup<TSource, TKey>(IQbservable<TSource>, Expression<Func<TSource, TKey>>, IEqualityComparer<TKey>)Creates a lookup from a queryable observable sequence according to a specified key selector function, and a comparer.
Public methodStatic memberToLookup<TSource, TKey, TElement>(IQbservable<TSource>, Expression<Func<TSource, TKey>>, Expression<Func<TSource, TElement>>)Creates a lookup from a queryable observable sequence according to a specified key selector function, and an element selector function.
Public methodStatic memberToLookup<TSource, TKey, TElement>(IQbservable<TSource>, Expression<Func<TSource, TKey>>, Expression<Func<TSource, TElement>>, IEqualityComparer<TKey>)Creates a lookup from a queryable observable sequence according to a specified key selector function, a comparer, and an element selector function.
Public methodStatic memberToObservable<TSource>(IQbservableProvider, IEnumerable<TSource>)Converts an enumerable sequence to a queryable observable sequence with a specified source.
Public methodStatic memberToObservable<TSource>(IQbservableProvider, IEnumerable<TSource>, IScheduler)Converts an enumerable sequence to a queryable observable sequence with a specified source and scheduler.
Public methodStatic memberToQbservable<TSource>Converts an enumerable sequence to a queryable observable sequence with a specified source.
Public methodStatic memberToQueryable<TSource>Converts an enumerable sequence to a queryable observable sequence with a specified source.
Public methodStatic memberUsing<TSource, TResource>Constructs a queryable observable sequence that depends on a resource object.
Public methodStatic memberWhen<TResult>(IQbservableProvider, IEnumerable<QueryablePlan<TResult>>)Joins together the results from several patterns.
Public methodStatic memberWhen<TResult>(IQbservableProvider, QueryablePlan<TResult>[])Joins together the results from several patterns.
Public methodStatic memberWhere<TSource>(IQbservable<TSource>, Expression<Func<TSource, Boolean>>)Filters the elements of a queryable observable sequence based on a predicate.
Public methodStatic memberWhere<TSource>(IQbservable<TSource>, Expression<Func<TSource, Int32, Boolean>>)Filters the elements of a queryable observable sequence based on a predicate by incorporating the element's index.
Public methodStatic memberWindow<TSource>(IQbservable<TSource>, Int32)Projects each element of a queryable observable sequence into consecutive non-overlapping windows which are produced based on element count information.
Public methodStatic memberWindow<TSource>(IQbservable<TSource>, TimeSpan)Projects each element of a queryable observable sequence into consecutive non-overlapping windows which are produced based on timing information.
Public methodStatic memberWindow<TSource>(IQbservable<TSource>, Int32, Int32)Projects each element of a queryable observable sequence into zero or more windows which are produced based on element count information.
Public methodStatic memberWindow<TSource>(IQbservable<TSource>, TimeSpan, Int32)Projects each element of a queryable observable sequence into a window that is completed when either it’s full or a given amount of time has elapsed.
Public methodStatic memberWindow<TSource>(IQbservable<TSource>, TimeSpan, IScheduler)Projects each element of a queryable observable sequence into consecutive non-overlapping windows which are produced based on timing information.
Public methodStatic memberWindow<TSource>(IQbservable<TSource>, TimeSpan, TimeSpan)Projects each element of a queryable observable sequence into zero or more windows which are produced based on timing information.
Public methodStatic memberWindow<TSource>(IQbservable<TSource>, TimeSpan, Int32, IScheduler)Projects each element of a queryable observable sequence into a window that is completed when either it’s full or a given amount of time has elapsed.
Public methodStatic memberWindow<TSource>(IQbservable<TSource>, TimeSpan, TimeSpan, IScheduler)Projects each element of a queryable observable sequence into zero or more windows which are produced based on timing information.
Public methodStatic memberWindow<TSource, TWindowClosing>(IQbservable<TSource>, Expression<Func<IObservable<TWindowClosing>>>)Projects each element of a queryable observable sequence into consecutive non-overlapping windows.
Public methodStatic memberWindow<TSource, TWindowOpening, TWindowClosing>(IQbservable<TSource>, IObservable<TWindowOpening>, Expression<Func<TWindowOpening, IObservable<TWindowClosing>>>)Projects each element of a queryable observable sequence into zero or more windows.
Public methodStatic memberZip<TFirst, TSecond, TResult>(IQbservable<TFirst>, IEnumerable<TSecond>, Expression<Func<TFirst, TSecond, TResult>>)Merges a queryable observable sequence and an enumerable sequence into one queryable observable sequence by using the selector function.
Public methodStatic memberZip<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

Any public static (Shared in Visual Basic) members of this type are thread safe. Any instance members are not guaranteed to be thread safe.
Show:
© 2014 Microsoft