Qbservable Methods

Include Protected Members
Include Inherited Members

The Qbservable type exposes the following members.

Methods

NameDescriptionAggregate(IQbservable, Expression<Func<TSource, TSource, TSource>>)Applies an accumulator function over a queryable observable sequence.Aggregate<TSource, TAccumulate>(IQbservable, TAccumulate, Expression<Func<TAccumulate, TSource, TAccumulate>>)Applies an accumulator function over a queryable observable sequence.AllDetermines whether all elements of a queryable observable sequence satisfies a condition.Amb(IQbservable, IObservable)Propagates the queryable observable sequence that reacts first with the specified first and second sequence.Amb(IQbservableProvider, IEnumerable<IObservable>)Propagates the queryable observable sequence that reacts first with a specified sources.Amb(IQbservableProvider, array<IObservable[])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(IQbservable)Determines whether a queryable observable sequence contains any elements.Any(IQbservable, Expression<Func<TSource, Boolean>>)Determines whether all elements of a queryable observable sequence satisfies a condition.AsObservableHides the identity of an observable sequence.AsQbservableConverts an observable sequence into a queryable observable sequence.Average(IQbservable)Computes the average of a queryable observable sequence of Decimal values.Average(IQbservable)Computes the average of a queryable observable sequence of Double values.Average(IQbservable)Computes the average of a queryable observable sequence of Int32 values.Average(IQbservable)Computes the average of a queryable observable sequence of Int64 values.Average(IQbservable<Nullable>)Computes the average of a queryable observable sequence of nullable Decimal values.Average(IQbservable<Nullable>)Computes the average of a queryable observable sequence of nullable Double values.Average(IQbservable<Nullable>)Computes the average of a queryable observable sequence of nullable Int32 values.Average(IQbservable<Nullable>)Computes the average of a queryable observable sequence of nullable Int64 values.Average(IQbservable<Nullable>)Computes the average of a queryable observable sequence of nullable Float values.Average(IQbservable)Computes the average of a queryable observable sequence of Float values.Buffer(IQbservable, Int32)Indicates each element of a queryable observable sequence into consecutive non-overlapping buffers which are produced based on element count information.Buffer(IQbservable, TimeSpan)Indicates each element of a queryable observable sequence into consecutive non-overlapping buffers which are produced based on timing information.Buffer(IQbservable, Int32, Int32)Indicates each element of a queryable observable sequence into zero or more buffers which are produced based on element count information.Buffer(IQbservable, 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(IQbservable, TimeSpan, IScheduler)Indicates each element of a queryable observable sequence into consecutive non-overlapping buffers which are produced based on timing information.Buffer(IQbservable, TimeSpan, TimeSpan)Indicates each element of a queryable observable sequence into zero or more buffers which are produced based on timing information.Buffer(IQbservable, 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(IQbservable, 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, Expression<Func<IObservable>>)Indicates each element of a queryable observable sequence into consecutive non-overlapping buffers.Buffer<TSource, TBufferOpening, TBufferClosing>(IQbservable, IObservable, Expression<Func<TBufferOpening, IObservable>>)Indicates each element of a queryable observable sequence into consecutive non-overlapping buffers.CastConverts the elements of an observable sequence to the specified type.Catch(IQbservable, IObservable)Continues a queryable observable sequence that is terminated by an exception with the next queryable observable sequence.Catch(IQbservableProvider, IEnumerable<IObservable>)Continues a queryable observable sequence that is terminated by an exception with the next queryableobservable sequence.Catch(IQbservableProvider, array<IObservable[])Continues a queryable observable sequence that is terminated by an exception with the next queryable observable sequence.Catch<TSource, TException>(IQbservable, Expression<Func<TException, IObservable>>)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(IQbservable<IObservable>)Concatenates an enumerable sequence of queryable observable sequences.Concat(IQbservable, IObservable)Concatenates two observable sequences.Concat(IQbservableProvider, IEnumerable<IObservable>)Concatenates all the queryable observable sequences.Concat(IQbservableProvider, array<IObservable[])Concatenates a queryable observable sequence of queryable observable sequences.Contains(IQbservable, TSource)Determines whether a queryable observable sequence contains a specified element by using the default equality comparer.Contains(IQbservable, TSource, IEqualityComparer)Determines whether an observable sequence contains a specified element by using a specified source type, source, value and comparer.CountReturns a [System.Int32] that represents the total number of elements in a queryable observable sequence.Create(IQbservableProvider, Expression<Func<IObserver, Action>>)Creates a queryable observable sequence from a specified subscribe method implementation with a specified subscribe.Create(IQbservableProvider, Expression<Func<IObserver, IDisposable>>)Creates a queryable observable sequence from a specified subscribe method implementation with a specified subscribe.DefaultIfEmpty(IQbservable)Returns the elements of the specified sequence or the type parameter's default value in a singleton sequence if the sequence is empty.DefaultIfEmpty(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.DeferReturns a queryable observable sequence that invokes the observable factory whenever a new observer subscribes.Delay(IQbservable, DateTimeOffset)Indicates the queryable observable sequence by due time with the specified source and dueTime.Delay(IQbservable, TimeSpan)Indicates the queryable observable sequence by due time with the specified source and dueTime.Delay(IQbservable, DateTimeOffset, IScheduler)Indicates the queryable observable sequence by due time with the specified source, dueTime and scheduler.Delay(IQbservable, TimeSpan, IScheduler)Indicates the queryable observable sequence by due time with the specified source, dueTime and scheduler.DematerializeDematerializes the explicit notification values of a queryable observable sequence as implicit notifications.Distinct(IQbservable)Returns a queryable observable sequence that contains only distinct elements with a specified source.Distinct(IQbservable, IEqualityComparer)Returns a queryable observable sequence that contains only distinct elements according to the comparer.Distinct<TSource, TKey>(IQbservable, Expression<Func<TSource, TKey>>)Returns a queryable observable sequence that contains only distinct elements according to the keySelector.Distinct<TSource, TKey>(IQbservable, Expression<Func<TSource, TKey>>, IEqualityComparer)Returns a queryable observable sequence that contains only distinct elements according to the keySelector and comparer.DistinctUntilChanged(IQbservable)Returns a queryable observable sequence that contains only distinct contiguous elements with a specified source.DistinctUntilChanged(IQbservable, IEqualityComparer)Returns a queryable observable sequence that contains only distinct contiguous elements according to the comparer.DistinctUntilChanged<TSource, TKey>(IQbservable, Expression<Func<TSource, TKey>>)Returns a queryable observable sequence that contains only distinct contiguous elements according to the keySelector.DistinctUntilChanged<TSource, TKey>(IQbservable, Expression<Func<TSource, TKey>>, IEqualityComparer)Returns a queryable observable sequence that contains only distinct contiguous elements according to the keySelector and the comparer.Do(IQbservable, IObserver)Invokes an action for each element in the queryable observable sequence.Do(IQbservable, Expression<Action>)Invokes an action for each element in the queryable observable sequence and invokes an action upon graceful termination of the queryable observable sequence.Do(IQbservable, Expression<Action>, Expression<Action>)Invokes an action for each element in the queryable observable sequence and invokes an action upon exceptional termination of the queryable observable sequence.Do(IQbservable, Expression<Action>, Expression)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(IQbservable, Expression<Action>, Expression<Action>, Expression)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.ElementAtReturns the element at a specified index in a sequence.ElementAtOrDefaultReturns the element at a specified index in a sequence or a default value if the index is out of range.Empty(IQbservableProvider)Returns an empty queryable observable sequence with the specified provider.Empty(IQbservableProvider, IScheduler)Returns an empty queryable observable sequence with the specified scheduler and provider.FinallyInvokes a specified action after source observable sequence terminates normally or by an exception.FromAsyncPattern(IQbservableProvider, Expression<Func<AsyncCallback, Object, IAsyncResult>>, Expression<Action>)Converts a Begin/End invoke function pair into an asynchronous function.FromAsyncPattern(IQbservableProvider, Expression<Func<AsyncCallback, Object, IAsyncResult>>, Expression<Func<IAsyncResult, TResult>>)Converts a Begin/End invoke function pair into an asynchronous function.FromAsyncPattern(IQbservableProvider, Expression<Func<T1, AsyncCallback, Object, IAsyncResult>>, Expression<Action>)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>)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>)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>)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>)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>)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>)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>)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>)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>)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>)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>)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>)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>)Converts a Begin/End invoke function pair into an asynchronous function.FromEvent(IQbservableProvider, Expression<Action>, Expression<Action>)Converts a .NET event to a queryable observable sequence.FromEvent(IQbservableProvider, Expression<Action<Action>>, Expression<Action<Action>>)Converts a .NET event to a queryable observable sequence.FromEvent<TDelegate, TEventArgs>(IQbservableProvider, Expression<Action>, Expression<Action>)Converts a .NET event to a queryable observable sequence.FromEvent<TDelegate, TEventArgs>(IQbservableProvider, Expression<Func<Action, TDelegate>>, Expression<Action>, Expression<Action>)Converts a .NET event to a queryable observable sequence.FromEventPattern(IQbservableProvider, Expression<Action>, Expression<Action>)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(IQbservableProvider, Expression<Action<EventHandler>>, Expression<Action<EventHandler>>)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(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(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>, Expression<Action>)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, TDelegate>>, Expression<Action>, Expression<Action>)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, Expression<Func<TSource, TKey>>)Groups the elements of a queryable observable sequence according to a specified key selector function.GroupBy<TSource, TKey>(IQbservable, Expression<Func<TSource, TKey>>, IEqualityComparer)Groups the elements of a queryable observable sequence according to a specified key selector function and comparer.GroupBy<TSource, TKey, TElement>(IQbservable, 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, Expression<Func<TSource, TKey>>, Expression<Func<TSource, TElement>>, IEqualityComparer)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, Expression<Func<TSource, TKey>>, Expression<Func<IGroupedObservable<TKey, TSource>, IObservable>>)Groups the elements of a queryable observable sequence according to a specified key selector function.GroupByUntil<TSource, TKey, TDuration>(IQbservable, Expression<Func<TSource, TKey>>, Expression<Func<IGroupedObservable<TKey, TSource>, IObservable>>, IEqualityComparer)Groups the elements of a queryable observable sequence according to a specified key selector function and comparer.GroupByUntil<TSource, TKey, TElement, TDuration>(IQbservable, Expression<Func<TSource, TKey>>, Expression<Func<TSource, TElement>>, Expression<Func<IGroupedObservable<TKey, TElement>, IObservable>>)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, Expression<Func<TSource, TKey>>, Expression<Func<TSource, TElement>>, Expression<Func<IGroupedObservable<TKey, TElement>, IObservable>>, IEqualityComparer)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.IgnoreElementsIgnores 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.LatestSamples the most recent value in a queryable observable sequence.LongCountReturns a [System.Int64] that represents the total number of elements in a queryable observable sequence.MaterializeMaterializes the implicit notifications of a queryable observable sequence as explicit notification values.Max(IQbservable)Returns the maximum value in a queryable observable sequence of Decimal values.Max(IQbservable)Returns the maximum value in a queryable observable sequence of Double values.Max(IQbservable)Returns the maximum value in a queryable observable sequence of Int32 values.Max(IQbservable)Returns the maximum value in a queryable observable sequence of Int64 values.Max(IQbservable<Nullable>)Returns the maximum value in a queryable observable sequence of nullable Decimal values.Max(IQbservable<Nullable>)Returns the maximum value in a queryable observable sequence of nullable Double values.Max(IQbservable<Nullable>)Returns the maximum value in a queryable observable sequence of nullable Int32 values.Max(IQbservable<Nullable>)Returns the maximum value in a queryable observable sequence of nullable Int64 values.Max(IQbservable<Nullable>)Returns the maximum value in a queryable observable sequence of nullable Float values.Max(IQbservable)Returns the maximum value in a queryable observable sequence of Float values.Max(IQbservable)Returns the maximum element in a queryable observable sequence.Max(IQbservable, IComparer)Returns the maximum value in a queryable observable sequence according to the specified comparer.MaxBy<TSource, TKey>(IQbservable, Expression<Func<TSource, TKey>>)Returns the elements in a queryable observable sequence with the maximum key value.MaxBy<TSource, TKey>(IQbservable, Expression<Func<TSource, TKey>>, IComparer)Returns the elements in a queryable observable sequence with the maximum key value.Merge(IQbservable<IObservable>)Merges all the queryable observable sequences into a single queryable observable sequence.Merge(IQbservable<IObservable>, Int32)Merges an enumerable sequence of queryable observable sequences into a queryable observable sequence, limiting the number of concurrent subscriptions to inner sequences.Merge(IQbservable, IObservable)Merges an enumerable sequence of queryable observable sequences into a single observable sequence.Merge(IQbservableProvider, IEnumerable<IObservable>)Merges an enumerable sequence of queryable observable sequences into a single queryable observable sequence.Merge(IQbservableProvider, array<IObservable[])Merges all the queryable observable sequences into a single queryable observable sequence.Merge(IQbservable, IObservable, IScheduler)Merges two queryable observable sequences into a single queryable observable sequence.Merge(IQbservableProvider, IEnumerable<IObservable>, Int32)Merges an enumerable sequence of queryable observable sequences into an queryable observable sequence, limiting the number of concurrent subscriptions to inner sequences.Merge(IQbservableProvider, IEnumerable<IObservable>, IScheduler)Merges an enumerable sequence of queryable observable sequences into a single queryable observable sequence.Merge(IQbservableProvider, IScheduler, array<IObservable[])Merges all the queryable observable sequences into a single queryable observable sequence.Merge(IQbservableProvider, IEnumerable<IObservable>, 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)Returns the minimum value in a queryable observable sequence of Decimal values.Min(IQbservable)Returns the minimum value in a queryable observable sequence of Double values.Min(IQbservable)Returns the minimum value in a queryable observable sequence of Int32 values.Min(IQbservable)Returns the minimum value in a queryable observable sequence of Int64 values.Min(IQbservable<Nullable>)Returns the minimum value in a queryable observable sequence of nullable Decimal values.Min(IQbservable<Nullable>)Returns the minimum value in a queryable observable sequence of nullable Double values.Min(IQbservable<Nullable>)Returns the minimum value in a queryable observable sequence of nullable Int32 values.Min(IQbservable<Nullable>)Returns the minimum value in a queryable observable sequence of nullable Int64 values.Min(IQbservable<Nullable>)Returns the minimum value in a queryable observable sequence of nullable Float values.Min(IQbservable)Returns the minimum value in a queryable observable sequence of Float values.Min(IQbservable)Returns the minimum element in a queryable observable sequence.Min(IQbservable, IComparer)Returns the minimum value in a queryable observable sequence according to the specified comparer.MinBy<TSource, TKey>(IQbservable, Expression<Func<TSource, TKey>>)Returns the elements in a queryable observable sequence with the minimum key value.MinBy<TSource, TKey>(IQbservable, Expression<Func<TSource, TKey>>, IComparer)Returns the elements in a queryable observable sequence with the minimum key value according to the specified comparer.MostRecentSamples 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.NeverReturns a non-terminating queryable observable sequence.NextSamples the next value (blocking without buffering) from in an queryable observable sequence.ObserveOn(IQbservable, IScheduler)Asynchronously notify observers on the specified synchronization context.ObserveOn(IQbservable, SynchronizationContext)Asynchronously notify observers on the specified synchronization context.OfTypeFilters the elements of a queryable observable sequence based on the specified type.OnErrorResumeNext(IQbservable, IObservable)Continues a queryable observable sequence that is terminated normally or by an exception with the next queryable observable sequence.OnErrorResumeNext(IQbservableProvider, IEnumerable<IObservable>)Continues a queryable observable sequence that is terminated normally or by an exception with the next queryable observable sequence.OnErrorResumeNext(IQbservableProvider, array<IObservable[])Continues a queryable observable sequence that is terminated normally or by an exception with the next queryable observable sequence.Publish<TSource, TResult>(IQbservable, Expression<Func<IObservable, IObservable>>)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, Expression<Func<IObservable, IObservable>>, 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.RefCountReturns 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(IQbservable)Repeats the queryable observable sequence indefinitely.Repeat(IQbservable, Int32)Repeats the queryable observable sequence indefinitely.Repeat(IQbservableProvider, TResult)Generates a queryable observable sequence that repeats the given element infinitely.Repeat(IQbservableProvider, TResult, Int32)Generates a queryable observable sequence that repeats the given element the specified number of times.Repeat(IQbservableProvider, TResult, IScheduler)Generates a queryable observable sequence that repeats the given element infinitely.Repeat(IQbservableProvider, TResult, Int32, IScheduler)Generates a queryable observable sequence that repeats the given element of the specified number of times.Replay<TSource, TResult>(IQbservable, Expression<Func<IObservable, IObservable>>)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, Expression<Func<IObservable, IObservable>>, 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, Expression<Func<IObservable, IObservable>>, 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, Expression<Func<IObservable, IObservable>>, 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, Expression<Func<IObservable, IObservable>>, 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, Expression<Func<IObservable, IObservable>>, 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, Expression<Func<IObservable, IObservable>>, 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, Expression<Func<IObservable, IObservable>>, 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(IQbservable)Repeats the source queryable observable sequence until it successfully terminates.Retry(IQbservable, Int32)Repeats the source queryable observable sequence until it successfully terminates.Return(IQbservableProvider, TResult)Returns a queryable observable sequence that contains a single element with a specified value.Return(IQbservableProvider, TResult, IScheduler)Returns a queryable observable sequence that contains a single value with a specified value and scheduler.Sample(IQbservable, TimeSpan)Samples the queryable observable sequence at each interval.Sample(IQbservable, TimeSpan, IScheduler)Samples the queryable observable sequence at each interval with the specified source, interval and scheduler.Sample<TSource, TSample>(IQbservable, IObservable)Samples the queryable observable sequence at sampling ticks with the specified source and sampler.Scan(IQbservable, 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, 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, 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, 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, IObservable)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, Expression<Func<TSource, IEnumerable>>)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, Expression<Func<TSource, IObservable>>)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, Expression<Func<TSource, IObservable>>, Expression<Func<Exception, IObservable>>, Expression<Func<IObservable>>)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, Expression<Func<TSource, IEnumerable>>, 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, Expression<Func<TSource, IObservable>>, 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(IQbservable, IObservable)Determines whether two sequences are equal by comparing the elements pairwise.SequenceEqual(IQbservable, IObservable, IEqualityComparer)Determines whether two sequences are equal by comparing the elements pairwise using a specified equality comparer.SkipBypasses a specified number of values in an observable sequence and then returns the remaining values.SkipLastBypasses 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(IQbservable, 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(IQbservable, 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)Invokes the action asynchronously.Start(IQbservableProvider, Expression, IScheduler)Invokes the action asynchronously.Start(IQbservableProvider, Expression<Func>)Invokes the function asynchronously.Start(IQbservableProvider, Expression<Func>, IScheduler)Invokes the function asynchronously.StartWith(IQbservable, array<TSource[])Prepends a sequence of values to a queryable observable sequence with the specified source and values.StartWith(IQbservable, IScheduler, array<TSource[])Prepends a sequence of values to a queryable observable sequence with the specified source, scheduler and values.SubscribeOn(IQbservable, IScheduler)Asynchronously subscribes and unsubscribes observers on the specified synchronization context.SubscribeOn(IQbservable, SynchronizationContext)Asynchronously subscribes and unsubscribes observers on the specified synchronization context.Sum(IQbservable)Computes the sum of a sequence of Decimal values.Sum(IQbservable)Computes the sum of a sequence of Double values.Sum(IQbservable)Computes the sum of a sequence of Int32 values.Sum(IQbservable)Computes the sum of a sequence of Int64 values.Sum(IQbservable<Nullable>)Computes the sum of a sequence of nullable Decimal values.Sum(IQbservable<Nullable>)Computes the sum of a sequence of nullable Double values.Sum(IQbservable<Nullable>)Computes the sum of a sequence of nullable Int32 values.Sum(IQbservable<Nullable>)Computes the sum of a sequence of nullable Int64 values.Sum(IQbservable<Nullable>)Computes the sum of a sequence of nullable Float values.Sum(IQbservable)Computes the sum of a sequence of Float values.SwitchTransforms a queryable observable sequence of queryable observable sequences into a queryable observable sequence producing values only from the most recent queryable observable sequence.Synchronize(IQbservable)Synchronizes the queryable observable sequence.Synchronize(IQbservable, Object)Synchronizes the queryable observable sequence.TakeReturns a specified number of contiguous values from the start of a queryable observable sequence.TakeLastReturns 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(IQbservable, 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(IQbservable, 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(IQbservable, 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(IQbservable, 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(IQbservableProvider, Exception)Returns a queryable observable sequence that terminates with an exception.Throw(IQbservableProvider, Exception, IScheduler)Returns a queryable observable sequence that terminates with an exception with the specified scheduler.TimeInterval(IQbservable)Records the time interval between consecutive values in a queryable observable sequence with the specified source.TimeInterval(IQbservable, IScheduler)Records the time interval between consecutive values in a queryable observable sequence with the specified source and scheduler.Timeout(IQbservable, DateTimeOffset)Returns either the queryable observable sequence or a TimeoutException if dueTime elapses.Timeout(IQbservable, TimeSpan)Returns either the queryable observable sequence or a TimeoutException if dueTime elapses.Timeout(IQbservable, DateTimeOffset, IObservable)Returns either the queryable observable sequence or an TimeoutException if dueTime elapses.Timeout(IQbservable, DateTimeOffset, IScheduler)Returns either the queryable observable sequence or a TimeoutException if dueTime elapses.Timeout(IQbservable, TimeSpan, IObservable)Returns the source queryable observable sequence or the other queryable observable sequence if dueTime elapses.Timeout(IQbservable, TimeSpan, IScheduler)Returns either the queryable observable sequence or a TimeoutException if dueTime elapses.Timeout(IQbservable, DateTimeOffset, IObservable, IScheduler)Returns the source queryable observable sequence or the other queryable observable sequence if dueTime elapses.Timeout(IQbservable, TimeSpan, IObservable, 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(IQbservable)Records the timestamp for each value in a queryable observable sequence with the specified source.Timestamp(IQbservable, IScheduler)Records the timestamp for each value in a queryable observable sequence with the specified source and scheduler.ToArrayCreates an array from a queryable observable sequence.ToAsync(IQbservableProvider, Expression)Converts the function into an asynchronous function.ToAsync(IQbservableProvider, Expression, IScheduler)Converts the function into an asynchronous function.ToAsync(IQbservableProvider, Expression<Action>)Converts the function into an asynchronous function.ToAsync(IQbservableProvider, Expression<Func>)Converts the function into an asynchronous function.ToAsync(IQbservableProvider, Expression<Action>, IScheduler)Converts the function into an asynchronous function.ToAsync(IQbservableProvider, Expression<Func>, 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, Expression<Func<TSource, TKey>>)Creates a dictionary from a queryable observable sequence according to a specified key selector function.ToDictionary<TSource, TKey>(IQbservable, Expression<Func<TSource, TKey>>, IEqualityComparer)Creates a dictionary from a queryable observable sequence according to a specified key selector function, and a comparer.ToDictionary<TSource, TKey, TElement>(IQbservable, 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, Expression<Func<TSource, TKey>>, Expression<Func<TSource, TElement>>, IEqualityComparer)Creates a dictionary from a queryable observable sequence according to a specified key selector function, a comparer, and an element selector function.ToListCreates a list from a queryable observable sequence.ToLookup<TSource, TKey>(IQbservable, Expression<Func<TSource, TKey>>)Creates a lookup from a queryable observable sequence according to a specified key selector function.ToLookup<TSource, TKey>(IQbservable, Expression<Func<TSource, TKey>>, IEqualityComparer)Creates a lookup from a queryable observable sequence according to a specified key selector function, and a comparer.ToLookup<TSource, TKey, TElement>(IQbservable, 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, Expression<Func<TSource, TKey>>, Expression<Func<TSource, TElement>>, IEqualityComparer)Creates a lookup from a queryable observable sequence according to a specified key selector function, a comparer, and an element selector function.ToObservable(IQbservableProvider, IEnumerable)Converts an enumerable sequence to a queryable observable sequence with a specified source.ToObservable(IQbservableProvider, IEnumerable, IScheduler)Converts an enumerable sequence to a queryable observable sequence with a specified source and scheduler.ToQbservableConverts an enumerable sequence to a queryable observable sequence with a specified source.ToQueryableConverts 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(IQbservableProvider, IEnumerable<QueryablePlan>)Joins together the results from several patterns.When(IQbservableProvider, array<QueryablePlan[])Joins together the results from several patterns.Where(IQbservable, Expression<Func<TSource, Boolean>>)Filters the elements of a queryable observable sequence based on a predicate.Where(IQbservable, Expression<Func<TSource, Int32, Boolean>>)Filters the elements of a queryable observable sequence based on a predicate by incorporating the element's index.Window(IQbservable, Int32)Projects each element of a queryable observable sequence into consecutive non-overlapping windows which are produced based on element count information.Window(IQbservable, TimeSpan)Projects each element of a queryable observable sequence into consecutive non-overlapping windows which are produced based on timing information.Window(IQbservable, Int32, Int32)Projects each element of a queryable observable sequence into zero or more windows which are produced based on element count information.Window(IQbservable, 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(IQbservable, TimeSpan, IScheduler)Projects each element of a queryable observable sequence into consecutive non-overlapping windows which are produced based on timing information.Window(IQbservable, TimeSpan, TimeSpan)Projects each element of a queryable observable sequence into zero or more windows which are produced based on timing information.Window(IQbservable, 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(IQbservable, 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, Expression<Func<IObservable>>)Projects each element of a queryable observable sequence into consecutive non-overlapping windows.Window<TSource, TWindowOpening, TWindowClosing>(IQbservable, IObservable, Expression<Func<TWindowOpening, IObservable>>)Projects each element of a queryable observable sequence into zero or more windows.Zip<TFirst, TSecond, TResult>(IQbservable, IEnumerable, 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, IObservable, Expression<Func<TFirst, TSecond, TResult>>)Merges two queryable observable sequences into one queryable observable sequence by combining their elements in a pairwise fashion.Top

See Also

Reference

Qbservable Class

System.Reactive.Linq Namespace

Qbservable Properties

Include Protected Members
Include Inherited Members

The Qbservable type exposes the following members.

Properties

NameDescriptionProviderGets the local Qbservable provider.Top

See Also

Reference

Qbservable Class

System.Reactive.Linq Namespace

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

NameDescriptionProviderGets the local Qbservable provider.Top

Methods

NameDescriptionAggregate(IQbservable, Expression<Func<TSource, TSource, TSource>>)Applies an accumulator function over a queryable observable sequence.Aggregate<TSource, TAccumulate>(IQbservable, TAccumulate, Expression<Func<TAccumulate, TSource, TAccumulate>>)Applies an accumulator function over a queryable observable sequence.AllDetermines whether all elements of a queryable observable sequence satisfies a condition.Amb(IQbservable, IObservable)Propagates the queryable observable sequence that reacts first with the specified first and second sequence.Amb(IQbservableProvider, IEnumerable<IObservable>)Propagates the queryable observable sequence that reacts first with a specified sources.Amb(IQbservableProvider, array<IObservable[])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(IQbservable)Determines whether a queryable observable sequence contains any elements.Any(IQbservable, Expression<Func<TSource, Boolean>>)Determines whether all elements of a queryable observable sequence satisfies a condition.AsObservableHides the identity of an observable sequence.AsQbservableConverts an observable sequence into a queryable observable sequence.Average(IQbservable)Computes the average of a queryable observable sequence of Decimal values.Average(IQbservable)Computes the average of a queryable observable sequence of Double values.Average(IQbservable)Computes the average of a queryable observable sequence of Int32 values.Average(IQbservable)Computes the average of a queryable observable sequence of Int64 values.Average(IQbservable<Nullable>)Computes the average of a queryable observable sequence of nullable Decimal values.Average(IQbservable<Nullable>)Computes the average of a queryable observable sequence of nullable Double values.Average(IQbservable<Nullable>)Computes the average of a queryable observable sequence of nullable Int32 values.Average(IQbservable<Nullable>)Computes the average of a queryable observable sequence of nullable Int64 values.Average(IQbservable<Nullable>)Computes the average of a queryable observable sequence of nullable Float values.Average(IQbservable)Computes the average of a queryable observable sequence of Float values.Buffer(IQbservable, Int32)Indicates each element of a queryable observable sequence into consecutive non-overlapping buffers which are produced based on element count information.Buffer(IQbservable, TimeSpan)Indicates each element of a queryable observable sequence into consecutive non-overlapping buffers which are produced based on timing information.Buffer(IQbservable, Int32, Int32)Indicates each element of a queryable observable sequence into zero or more buffers which are produced based on element count information.Buffer(IQbservable, 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(IQbservable, TimeSpan, IScheduler)Indicates each element of a queryable observable sequence into consecutive non-overlapping buffers which are produced based on timing information.Buffer(IQbservable, TimeSpan, TimeSpan)Indicates each element of a queryable observable sequence into zero or more buffers which are produced based on timing information.Buffer(IQbservable, 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(IQbservable, 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, Expression<Func<IObservable>>)Indicates each element of a queryable observable sequence into consecutive non-overlapping buffers.Buffer<TSource, TBufferOpening, TBufferClosing>(IQbservable, IObservable, Expression<Func<TBufferOpening, IObservable>>)Indicates each element of a queryable observable sequence into consecutive non-overlapping buffers.CastConverts the elements of an observable sequence to the specified type.Catch(IQbservable, IObservable)Continues a queryable observable sequence that is terminated by an exception with the next queryable observable sequence.Catch(IQbservableProvider, IEnumerable<IObservable>)Continues a queryable observable sequence that is terminated by an exception with the next queryableobservable sequence.Catch(IQbservableProvider, array<IObservable[])Continues a queryable observable sequence that is terminated by an exception with the next queryable observable sequence.Catch<TSource, TException>(IQbservable, Expression<Func<TException, IObservable>>)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(IQbservable<IObservable>)Concatenates an enumerable sequence of queryable observable sequences.Concat(IQbservable, IObservable)Concatenates two observable sequences.Concat(IQbservableProvider, IEnumerable<IObservable>)Concatenates all the queryable observable sequences.Concat(IQbservableProvider, array<IObservable[])Concatenates a queryable observable sequence of queryable observable sequences.Contains(IQbservable, TSource)Determines whether a queryable observable sequence contains a specified element by using the default equality comparer.Contains(IQbservable, TSource, IEqualityComparer)Determines whether an observable sequence contains a specified element by using a specified source type, source, value and comparer.CountReturns a [System.Int32] that represents the total number of elements in a queryable observable sequence.Create(IQbservableProvider, Expression<Func<IObserver, Action>>)Creates a queryable observable sequence from a specified subscribe method implementation with a specified subscribe.Create(IQbservableProvider, Expression<Func<IObserver, IDisposable>>)Creates a queryable observable sequence from a specified subscribe method implementation with a specified subscribe.DefaultIfEmpty(IQbservable)Returns the elements of the specified sequence or the type parameter's default value in a singleton sequence if the sequence is empty.DefaultIfEmpty(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.DeferReturns a queryable observable sequence that invokes the observable factory whenever a new observer subscribes.Delay(IQbservable, DateTimeOffset)Indicates the queryable observable sequence by due time with the specified source and dueTime.Delay(IQbservable, TimeSpan)Indicates the queryable observable sequence by due time with the specified source and dueTime.Delay(IQbservable, DateTimeOffset, IScheduler)Indicates the queryable observable sequence by due time with the specified source, dueTime and scheduler.Delay(IQbservable, TimeSpan, IScheduler)Indicates the queryable observable sequence by due time with the specified source, dueTime and scheduler.DematerializeDematerializes the explicit notification values of a queryable observable sequence as implicit notifications.Distinct(IQbservable)Returns a queryable observable sequence that contains only distinct elements with a specified source.Distinct(IQbservable, IEqualityComparer)Returns a queryable observable sequence that contains only distinct elements according to the comparer.Distinct<TSource, TKey>(IQbservable, Expression<Func<TSource, TKey>>)Returns a queryable observable sequence that contains only distinct elements according to the keySelector.Distinct<TSource, TKey>(IQbservable, Expression<Func<TSource, TKey>>, IEqualityComparer)Returns a queryable observable sequence that contains only distinct elements according to the keySelector and comparer.DistinctUntilChanged(IQbservable)Returns a queryable observable sequence that contains only distinct contiguous elements with a specified source.DistinctUntilChanged(IQbservable, IEqualityComparer)Returns a queryable observable sequence that contains only distinct contiguous elements according to the comparer.DistinctUntilChanged<TSource, TKey>(IQbservable, Expression<Func<TSource, TKey>>)Returns a queryable observable sequence that contains only distinct contiguous elements according to the keySelector.DistinctUntilChanged<TSource, TKey>(IQbservable, Expression<Func<TSource, TKey>>, IEqualityComparer)Returns a queryable observable sequence that contains only distinct contiguous elements according to the keySelector and the comparer.Do(IQbservable, IObserver)Invokes an action for each element in the queryable observable sequence.Do(IQbservable, Expression<Action>)Invokes an action for each element in the queryable observable sequence and invokes an action upon graceful termination of the queryable observable sequence.Do(IQbservable, Expression<Action>, Expression<Action>)Invokes an action for each element in the queryable observable sequence and invokes an action upon exceptional termination of the queryable observable sequence.Do(IQbservable, Expression<Action>, Expression)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(IQbservable, Expression<Action>, Expression<Action>, Expression)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.ElementAtReturns the element at a specified index in a sequence.ElementAtOrDefaultReturns the element at a specified index in a sequence or a default value if the index is out of range.Empty(IQbservableProvider)Returns an empty queryable observable sequence with the specified provider.Empty(IQbservableProvider, IScheduler)Returns an empty queryable observable sequence with the specified scheduler and provider.FinallyInvokes a specified action after source observable sequence terminates normally or by an exception.FromAsyncPattern(IQbservableProvider, Expression<Func<AsyncCallback, Object, IAsyncResult>>, Expression<Action>)Converts a Begin/End invoke function pair into an asynchronous function.FromAsyncPattern(IQbservableProvider, Expression<Func<AsyncCallback, Object, IAsyncResult>>, Expression<Func<IAsyncResult, TResult>>)Converts a Begin/End invoke function pair into an asynchronous function.FromAsyncPattern(IQbservableProvider, Expression<Func<T1, AsyncCallback, Object, IAsyncResult>>, Expression<Action>)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>)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>)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>)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>)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>)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>)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>)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>)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>)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>)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>)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>)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>)Converts a Begin/End invoke function pair into an asynchronous function.FromEvent(IQbservableProvider, Expression<Action>, Expression<Action>)Converts a .NET event to a queryable observable sequence.FromEvent(IQbservableProvider, Expression<Action<Action>>, Expression<Action<Action>>)Converts a .NET event to a queryable observable sequence.FromEvent<TDelegate, TEventArgs>(IQbservableProvider, Expression<Action>, Expression<Action>)Converts a .NET event to a queryable observable sequence.FromEvent<TDelegate, TEventArgs>(IQbservableProvider, Expression<Func<Action, TDelegate>>, Expression<Action>, Expression<Action>)Converts a .NET event to a queryable observable sequence.FromEventPattern(IQbservableProvider, Expression<Action>, Expression<Action>)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(IQbservableProvider, Expression<Action<EventHandler>>, Expression<Action<EventHandler>>)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(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(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>, Expression<Action>)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, TDelegate>>, Expression<Action>, Expression<Action>)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, Expression<Func<TSource, TKey>>)Groups the elements of a queryable observable sequence according to a specified key selector function.GroupBy<TSource, TKey>(IQbservable, Expression<Func<TSource, TKey>>, IEqualityComparer)Groups the elements of a queryable observable sequence according to a specified key selector function and comparer.GroupBy<TSource, TKey, TElement>(IQbservable, 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, Expression<Func<TSource, TKey>>, Expression<Func<TSource, TElement>>, IEqualityComparer)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, Expression<Func<TSource, TKey>>, Expression<Func<IGroupedObservable<TKey, TSource>, IObservable>>)Groups the elements of a queryable observable sequence according to a specified key selector function.GroupByUntil<TSource, TKey, TDuration>(IQbservable, Expression<Func<TSource, TKey>>, Expression<Func<IGroupedObservable<TKey, TSource>, IObservable>>, IEqualityComparer)Groups the elements of a queryable observable sequence according to a specified key selector function and comparer.GroupByUntil<TSource, TKey, TElement, TDuration>(IQbservable, Expression<Func<TSource, TKey>>, Expression<Func<TSource, TElement>>, Expression<Func<IGroupedObservable<TKey, TElement>, IObservable>>)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, Expression<Func<TSource, TKey>>, Expression<Func<TSource, TElement>>, Expression<Func<IGroupedObservable<TKey, TElement>, IObservable>>, IEqualityComparer)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.IgnoreElementsIgnores 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.LatestSamples the most recent value in a queryable observable sequence.LongCountReturns a [System.Int64] that represents the total number of elements in a queryable observable sequence.MaterializeMaterializes the implicit notifications of a queryable observable sequence as explicit notification values.Max(IQbservable)Returns the maximum value in a queryable observable sequence of Decimal values.Max(IQbservable)Returns the maximum value in a queryable observable sequence of Double values.Max(IQbservable)Returns the maximum value in a queryable observable sequence of Int32 values.Max(IQbservable)Returns the maximum value in a queryable observable sequence of Int64 values.Max(IQbservable<Nullable>)Returns the maximum value in a queryable observable sequence of nullable Decimal values.Max(IQbservable<Nullable>)Returns the maximum value in a queryable observable sequence of nullable Double values.Max(IQbservable<Nullable>)Returns the maximum value in a queryable observable sequence of nullable Int32 values.Max(IQbservable<Nullable>)Returns the maximum value in a queryable observable sequence of nullable Int64 values.Max(IQbservable<Nullable>)Returns the maximum value in a queryable observable sequence of nullable Float values.Max(IQbservable)Returns the maximum value in a queryable observable sequence of Float values.Max(IQbservable)Returns the maximum element in a queryable observable sequence.Max(IQbservable, IComparer)Returns the maximum value in a queryable observable sequence according to the specified comparer.MaxBy<TSource, TKey>(IQbservable, Expression<Func<TSource, TKey>>)Returns the elements in a queryable observable sequence with the maximum key value.MaxBy<TSource, TKey>(IQbservable, Expression<Func<TSource, TKey>>, IComparer)Returns the elements in a queryable observable sequence with the maximum key value.Merge(IQbservable<IObservable>)Merges all the queryable observable sequences into a single queryable observable sequence.Merge(IQbservable<IObservable>, Int32)Merges an enumerable sequence of queryable observable sequences into a queryable observable sequence, limiting the number of concurrent subscriptions to inner sequences.Merge(IQbservable, IObservable)Merges an enumerable sequence of queryable observable sequences into a single observable sequence.Merge(IQbservableProvider, IEnumerable<IObservable>)Merges an enumerable sequence of queryable observable sequences into a single queryable observable sequence.Merge(IQbservableProvider, array<IObservable[])Merges all the queryable observable sequences into a single queryable observable sequence.Merge(IQbservable, IObservable, IScheduler)Merges two queryable observable sequences into a single queryable observable sequence.Merge(IQbservableProvider, IEnumerable<IObservable>, Int32)Merges an enumerable sequence of queryable observable sequences into an queryable observable sequence, limiting the number of concurrent subscriptions to inner sequences.Merge(IQbservableProvider, IEnumerable<IObservable>, IScheduler)Merges an enumerable sequence of queryable observable sequences into a single queryable observable sequence.Merge(IQbservableProvider, IScheduler, array<IObservable[])Merges all the queryable observable sequences into a single queryable observable sequence.Merge(IQbservableProvider, IEnumerable<IObservable>, 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)Returns the minimum value in a queryable observable sequence of Decimal values.Min(IQbservable)Returns the minimum value in a queryable observable sequence of Double values.Min(IQbservable)Returns the minimum value in a queryable observable sequence of Int32 values.Min(IQbservable)Returns the minimum value in a queryable observable sequence of Int64 values.Min(IQbservable<Nullable>)Returns the minimum value in a queryable observable sequence of nullable Decimal values.Min(IQbservable<Nullable>)Returns the minimum value in a queryable observable sequence of nullable Double values.Min(IQbservable<Nullable>)Returns the minimum value in a queryable observable sequence of nullable Int32 values.Min(IQbservable<Nullable>)Returns the minimum value in a queryable observable sequence of nullable Int64 values.Min(IQbservable<Nullable>)Returns the minimum value in a queryable observable sequence of nullable Float values.Min(IQbservable)Returns the minimum value in a queryable observable sequence of Float values.Min(IQbservable)Returns the minimum element in a queryable observable sequence.Min(IQbservable, IComparer)Returns the minimum value in a queryable observable sequence according to the specified comparer.MinBy<TSource, TKey>(IQbservable, Expression<Func<TSource, TKey>>)Returns the elements in a queryable observable sequence with the minimum key value.MinBy<TSource, TKey>(IQbservable, Expression<Func<TSource, TKey>>, IComparer)Returns the elements in a queryable observable sequence with the minimum key value according to the specified comparer.MostRecentSamples 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.NeverReturns a non-terminating queryable observable sequence.NextSamples the next value (blocking without buffering) from in an queryable observable sequence.ObserveOn(IQbservable, IScheduler)Asynchronously notify observers on the specified synchronization context.ObserveOn(IQbservable, SynchronizationContext)Asynchronously notify observers on the specified synchronization context.OfTypeFilters the elements of a queryable observable sequence based on the specified type.OnErrorResumeNext(IQbservable, IObservable)Continues a queryable observable sequence that is terminated normally or by an exception with the next queryable observable sequence.OnErrorResumeNext(IQbservableProvider, IEnumerable<IObservable>)Continues a queryable observable sequence that is terminated normally or by an exception with the next queryable observable sequence.OnErrorResumeNext(IQbservableProvider, array<IObservable[])Continues a queryable observable sequence that is terminated normally or by an exception with the next queryable observable sequence.Publish<TSource, TResult>(IQbservable, Expression<Func<IObservable, IObservable>>)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, Expression<Func<IObservable, IObservable>>, 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.RefCountReturns 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(IQbservable)Repeats the queryable observable sequence indefinitely.Repeat(IQbservable, Int32)Repeats the queryable observable sequence indefinitely.Repeat(IQbservableProvider, TResult)Generates a queryable observable sequence that repeats the given element infinitely.Repeat(IQbservableProvider, TResult, Int32)Generates a queryable observable sequence that repeats the given element the specified number of times.Repeat(IQbservableProvider, TResult, IScheduler)Generates a queryable observable sequence that repeats the given element infinitely.Repeat(IQbservableProvider, TResult, Int32, IScheduler)Generates a queryable observable sequence that repeats the given element of the specified number of times.Replay<TSource, TResult>(IQbservable, Expression<Func<IObservable, IObservable>>)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, Expression<Func<IObservable, IObservable>>, 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, Expression<Func<IObservable, IObservable>>, 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, Expression<Func<IObservable, IObservable>>, 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, Expression<Func<IObservable, IObservable>>, 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, Expression<Func<IObservable, IObservable>>, 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, Expression<Func<IObservable, IObservable>>, 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, Expression<Func<IObservable, IObservable>>, 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(IQbservable)Repeats the source queryable observable sequence until it successfully terminates.Retry(IQbservable, Int32)Repeats the source queryable observable sequence until it successfully terminates.Return(IQbservableProvider, TResult)Returns a queryable observable sequence that contains a single element with a specified value.Return(IQbservableProvider, TResult, IScheduler)Returns a queryable observable sequence that contains a single value with a specified value and scheduler.Sample(IQbservable, TimeSpan)Samples the queryable observable sequence at each interval.Sample(IQbservable, TimeSpan, IScheduler)Samples the queryable observable sequence at each interval with the specified source, interval and scheduler.Sample<TSource, TSample>(IQbservable, IObservable)Samples the queryable observable sequence at sampling ticks with the specified source and sampler.Scan(IQbservable, 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, 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, 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, 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, IObservable)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, Expression<Func<TSource, IEnumerable>>)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, Expression<Func<TSource, IObservable>>)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, Expression<Func<TSource, IObservable>>, Expression<Func<Exception, IObservable>>, Expression<Func<IObservable>>)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, Expression<Func<TSource, IEnumerable>>, 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, Expression<Func<TSource, IObservable>>, 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(IQbservable, IObservable)Determines whether two sequences are equal by comparing the elements pairwise.SequenceEqual(IQbservable, IObservable, IEqualityComparer)Determines whether two sequences are equal by comparing the elements pairwise using a specified equality comparer.SkipBypasses a specified number of values in an observable sequence and then returns the remaining values.SkipLastBypasses 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(IQbservable, 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(IQbservable, 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)Invokes the action asynchronously.Start(IQbservableProvider, Expression, IScheduler)Invokes the action asynchronously.Start(IQbservableProvider, Expression<Func>)Invokes the function asynchronously.Start(IQbservableProvider, Expression<Func>, IScheduler)Invokes the function asynchronously.StartWith(IQbservable, array<TSource[])Prepends a sequence of values to a queryable observable sequence with the specified source and values.StartWith(IQbservable, IScheduler, array<TSource[])Prepends a sequence of values to a queryable observable sequence with the specified source, scheduler and values.SubscribeOn(IQbservable, IScheduler)Asynchronously subscribes and unsubscribes observers on the specified synchronization context.SubscribeOn(IQbservable, SynchronizationContext)Asynchronously subscribes and unsubscribes observers on the specified synchronization context.Sum(IQbservable)Computes the sum of a sequence of Decimal values.Sum(IQbservable)Computes the sum of a sequence of Double values.Sum(IQbservable)Computes the sum of a sequence of Int32 values.Sum(IQbservable)Computes the sum of a sequence of Int64 values.Sum(IQbservable<Nullable>)Computes the sum of a sequence of nullable Decimal values.Sum(IQbservable<Nullable>)Computes the sum of a sequence of nullable Double values.Sum(IQbservable<Nullable>)Computes the sum of a sequence of nullable Int32 values.Sum(IQbservable<Nullable>)Computes the sum of a sequence of nullable Int64 values.Sum(IQbservable<Nullable>)Computes the sum of a sequence of nullable Float values.Sum(IQbservable)Computes the sum of a sequence of Float values.SwitchTransforms a queryable observable sequence of queryable observable sequences into a queryable observable sequence producing values only from the most recent queryable observable sequence.Synchronize(IQbservable)Synchronizes the queryable observable sequence.Synchronize(IQbservable, Object)Synchronizes the queryable observable sequence.TakeReturns a specified number of contiguous values from the start of a queryable observable sequence.TakeLastReturns 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(IQbservable, 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(IQbservable, 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(IQbservable, 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(IQbservable, 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(IQbservableProvider, Exception)Returns a queryable observable sequence that terminates with an exception.Throw(IQbservableProvider, Exception, IScheduler)Returns a queryable observable sequence that terminates with an exception with the specified scheduler.TimeInterval(IQbservable)Records the time interval between consecutive values in a queryable observable sequence with the specified source.TimeInterval(IQbservable, IScheduler)Records the time interval between consecutive values in a queryable observable sequence with the specified source and scheduler.Timeout(IQbservable, DateTimeOffset)Returns either the queryable observable sequence or a TimeoutException if dueTime elapses.Timeout(IQbservable, TimeSpan)Returns either the queryable observable sequence or a TimeoutException if dueTime elapses.Timeout(IQbservable, DateTimeOffset, IObservable)Returns either the queryable observable sequence or an TimeoutException if dueTime elapses.Timeout(IQbservable, DateTimeOffset, IScheduler)Returns either the queryable observable sequence or a TimeoutException if dueTime elapses.Timeout(IQbservable, TimeSpan, IObservable)Returns the source queryable observable sequence or the other queryable observable sequence if dueTime elapses.Timeout(IQbservable, TimeSpan, IScheduler)Returns either the queryable observable sequence or a TimeoutException if dueTime elapses.Timeout(IQbservable, DateTimeOffset, IObservable, IScheduler)Returns the source queryable observable sequence or the other queryable observable sequence if dueTime elapses.Timeout(IQbservable, TimeSpan, IObservable, 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(IQbservable)Records the timestamp for each value in a queryable observable sequence with the specified source.Timestamp(IQbservable, IScheduler)Records the timestamp for each value in a queryable observable sequence with the specified source and scheduler.ToArrayCreates an array from a queryable observable sequence.ToAsync(IQbservableProvider, Expression)Converts the function into an asynchronous function.ToAsync(IQbservableProvider, Expression, IScheduler)Converts the function into an asynchronous function.ToAsync(IQbservableProvider, Expression<Action>)Converts the function into an asynchronous function.ToAsync(IQbservableProvider, Expression<Func>)Converts the function into an asynchronous function.ToAsync(IQbservableProvider, Expression<Action>, IScheduler)Converts the function into an asynchronous function.ToAsync(IQbservableProvider, Expression<Func>, 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, Expression<Func<TSource, TKey>>)Creates a dictionary from a queryable observable sequence according to a specified key selector function.ToDictionary<TSource, TKey>(IQbservable, Expression<Func<TSource, TKey>>, IEqualityComparer)Creates a dictionary from a queryable observable sequence according to a specified key selector function, and a comparer.ToDictionary<TSource, TKey, TElement>(IQbservable, 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, Expression<Func<TSource, TKey>>, Expression<Func<TSource, TElement>>, IEqualityComparer)Creates a dictionary from a queryable observable sequence according to a specified key selector function, a comparer, and an element selector function.ToListCreates a list from a queryable observable sequence.ToLookup<TSource, TKey>(IQbservable, Expression<Func<TSource, TKey>>)Creates a lookup from a queryable observable sequence according to a specified key selector function.ToLookup<TSource, TKey>(IQbservable, Expression<Func<TSource, TKey>>, IEqualityComparer)Creates a lookup from a queryable observable sequence according to a specified key selector function, and a comparer.ToLookup<TSource, TKey, TElement>(IQbservable, 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, Expression<Func<TSource, TKey>>, Expression<Func<TSource, TElement>>, IEqualityComparer)Creates a lookup from a queryable observable sequence according to a specified key selector function, a comparer, and an element selector function.ToObservable(IQbservableProvider, IEnumerable)Converts an enumerable sequence to a queryable observable sequence with a specified source.ToObservable(IQbservableProvider, IEnumerable, IScheduler)Converts an enumerable sequence to a queryable observable sequence with a specified source and scheduler.ToQbservableConverts an enumerable sequence to a queryable observable sequence with a specified source.ToQueryableConverts 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(IQbservableProvider, IEnumerable<QueryablePlan>)Joins together the results from several patterns.When(IQbservableProvider, array<QueryablePlan[])Joins together the results from several patterns.Where(IQbservable, Expression<Func<TSource, Boolean>>)Filters the elements of a queryable observable sequence based on a predicate.Where(IQbservable, Expression<Func<TSource, Int32, Boolean>>)Filters the elements of a queryable observable sequence based on a predicate by incorporating the element's index.Window(IQbservable, Int32)Projects each element of a queryable observable sequence into consecutive non-overlapping windows which are produced based on element count information.Window(IQbservable, TimeSpan)Projects each element of a queryable observable sequence into consecutive non-overlapping windows which are produced based on timing information.Window(IQbservable, Int32, Int32)Projects each element of a queryable observable sequence into zero or more windows which are produced based on element count information.Window(IQbservable, 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(IQbservable, TimeSpan, IScheduler)Projects each element of a queryable observable sequence into consecutive non-overlapping windows which are produced based on timing information.Window(IQbservable, TimeSpan, TimeSpan)Projects each element of a queryable observable sequence into zero or more windows which are produced based on timing information.Window(IQbservable, 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(IQbservable, 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, Expression<Func<IObservable>>)Projects each element of a queryable observable sequence into consecutive non-overlapping windows.Window<TSource, TWindowOpening, TWindowClosing>(IQbservable, IObservable, Expression<Func<TWindowOpening, IObservable>>)Projects each element of a queryable observable sequence into zero or more windows.Zip<TFirst, TSecond, TResult>(IQbservable, IEnumerable, 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, IObservable, Expression<Func<TFirst, TSecond, TResult>>)Merges two queryable observable sequences into one queryable observable sequence by combining their elements in a pairwise fashion.Top

Thread Safety

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

See Also

Reference

System.Reactive.Linq Namespace