This topic has not yet been rated - Rate this topic

Observable Class

Provides a set of static methods for query operations over observable sequences.

System.Object
System.Reactive.Linq.Observable

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

public final class Observable

The Observable type exposes the following members.

Methods

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

Reference

System.Reactive.Linq Namespace

Did you find this helpful? Yes No

Not accurate

Not enough depth

Need more code examples

(1500 characters remaining)