This topic has not yet been rated - Rate this topic

# Observable Methods

March 22, 2012

The Observable type exposes the following members.

NameDescription
Aggregate<TSource>(IObservable<TSource>, Func<TSource, TSource, TSource>) Applies an accumulator function over an observable sequence. The specified seed value is used as the initial accumulator value.
Aggregate<TSource, TAccumulate>(IObservable<TSource>, TAccumulate, Func<TAccumulate, TSource, TAccumulate>) Applies an accumulator function over an observable sequence. The specified seed value is used as the initial accumulator value.
All<TSource> Determines whether all values of an observable sequence satisfy a condition.
Amb<TSource>(IEnumerable<IObservable<TSource>>) Returns the observable sequence that reacts first.
Amb<TSource>(IObservable<TSource>[]) Returns the observable sequence that reacts first.
Amb<TSource>(IObservable<TSource>, IObservable<TSource>) Returns the observable sequence that reacts first.
And<TLeft, TRight> Matches when both observable sequences have an available value.
Any<TSource>(IObservable<TSource>) Determines whether an observable sequence contains any values.
Any<TSource>(IObservable<TSource>, Func<TSource, Boolean>) Determines whether an observable sequence contains any values.
AsObservable<TSource> Hides the identity of an observable sequence.
Average(IObservable<Decimal>) Computes the average of an observable sequence of values.
Average(IObservable<Double>) Computes the average of an observable sequence of values.
Average(IObservable<Int32>) Computes the average of an observable sequence of values.
Average(IObservable<Int64>) Computes the average of an observable sequence of values.
Average(IObservable<Nullable<Decimal>>) Computes the average of an observable sequence of values.
Average(IObservable<Nullable<Double>>) Computes the average of an observable sequence of values.
Average(IObservable<Nullable<Int32>>) Computes the average of an observable sequence of values.
Average(IObservable<Nullable<Int64>>) Computes the average of an observable sequence of values.
Average(IObservable<Nullable<Single>>) Computes the average of an observable sequence of values.
Average(IObservable<Single>) Computes the average of an observable sequence of values.
BufferWithCount<TSource>(IObservable<TSource>, Int32) Projects each value of an observable sequence into a buffer.
BufferWithCount<TSource>(IObservable<TSource>, Int32, Int32) Projects each value of an observable sequence into a buffer.
BufferWithTime<TSource>(IObservable<TSource>, TimeSpan) Projects each value of an observable sequence into a buffer.
BufferWithTime<TSource>(IObservable<TSource>, TimeSpan, IScheduler) Projects each value of an observable sequence into a buffer.
BufferWithTime<TSource>(IObservable<TSource>, TimeSpan, TimeSpan) Projects each value of an observable sequence into a buffer.
BufferWithTime<TSource>(IObservable<TSource>, TimeSpan, TimeSpan, IScheduler) Projects each value of an observable sequence into a buffer.
BufferWithTimeOrCount<TSource>(IObservable<TSource>, TimeSpan, Int32) Projects each value of an observable sequence into a buffer that's sent out when either it's full or a given amount of time has elapsed.
BufferWithTimeOrCount<TSource>(IObservable<TSource>, TimeSpan, Int32, IScheduler) Projects each value of an observable sequence into a buffer that's sent out when either it's full or a given amount of time has elapsed.
Case<TValue, TResult>(Func<TValue>, IDictionary<TValue, IObservable<TResult>>) Uses selector to determine which source in sources to use; empty if no match is found.
Case<TValue, TResult>(Func<TValue>, IDictionary<TValue, IObservable<TResult>>, IScheduler) Uses selector to determine which source in sources to use; empty if no match is found.
Case<TValue, TResult>(Func<TValue>, IDictionary<TValue, IObservable<TResult>>, IObservable<TResult>) Uses selector to determine which source in sources to use; uses the specified default source if no match is found.
Cast<TResult> Casts values to the given 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 with the next observable sequence.
CombineLatest<TLeft, TRight, TResult> Merges two observable sequences into one observable sequence by using the selector function whenever one of the observable sequences has a new value.
Concat<TSource>(IEnumerable<IObservable<TSource>>) Concatenates all the 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 value by using the default comparer.
Contains<TSource>(IObservable<TSource>, TSource, IEqualityComparer<TSource>) Determines whether an observable sequence contains a specified value by using the specified comparer.
Count<TSource> Returns the number of elements in an observable sequence.
Create<TSource> Creates an observable sequence from the subscribe implementation.
CreateWithDisposable<TSource> Creates an observable sequence from the subscribe implementation.
Defer<TValue> Returns an observable sequence that invokes the observableFactory function whenever a new observer subscribes.
Delay<TSource>(IObservable<TSource>, DateTimeOffset) Time-shifts the observable sequence by the specified time span. The relative time intervals between the values are preserved.
Delay<TSource>(IObservable<TSource>, TimeSpan) Time-shifts the observable sequence by the specified time span. The relative time intervals between the values are preserved.
Delay<TSource>(IObservable<TSource>, DateTimeOffset, IScheduler) Time-shifts the observable sequence by the specified time span. The relative time intervals between the values are preserved.
Delay<TSource>(IObservable<TSource>, TimeSpan, IScheduler) Time-shifts the observable sequence by the specified time span. The relative time intervals between the values are preserved.
Dematerialize<TSource> Dematerializes the explicit notification values of an observable sequence as implicit notifications.
DistinctUntilChanged<TSource>(IObservable<TSource>) Returns an observable sequence that contains only distinct contiguous values.
DistinctUntilChanged<TSource>(IObservable<TSource>, IEqualityComparer<TSource>) Returns an observable sequence that contains only distinct contiguous values according to the comparer.
DistinctUntilChanged<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>) Returns an observable sequence that contains only distinct contiguous values according to the specified key selector function.
DistinctUntilChanged<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>, IEqualityComparer<TKey>) Returns an observable sequence that contains only distinct contiguous values according to the specified key selector function and comparer.
Do<TSource>(IObservable<TSource>, Action<TSource>) Invokes the action for its side effects on each value in the observable sequence.
Do<TSource>(IObservable<TSource>, IObserver<TSource>) Invokes the action for its side effects on each value in the observable sequence.
Do<TSource>(IObservable<TSource>, Action<TSource>, Action) Invokes the action for its side effects on each value in the observable sequence.
Do<TSource>(IObservable<TSource>, Action<TSource>, Action<Exception>) Invokes the action for its side effects on each value in the observable sequence.
Do<TSource>(IObservable<TSource>, Action<TSource>, Action<Exception>, Action) Invokes the action for its side effects on each value in the observable sequence.
DoWhile<TSource> Repeats source as long as condition holds.
Empty<TValue>() Returns an empty observable sequence.
Empty<TValue>(IScheduler) Returns an empty observable sequence.
Finally<TSource> Invokes finallyAction after the source observable sequence terminates normally or by an exception.
First<TSource> Returns the first value of an observable sequence.
FirstOrDefault<TSource> Returns the first value of an observable sequence, or a default value if no value is found.
For<TSource, TResult> Concatenates the observable sequences obtained by running the specified result selector for each element in source.
ForkJoin<TSource>(IEnumerable<IObservable<TSource>>) Runs all observable sequences in parallel and combines their last values.
ForkJoin<TSource>(IObservable<TSource>[]) Runs all observable sequences in parallel and combines their first values.
ForkJoin<TLeft, TRight, TResult>(IObservable<TLeft>, IObservable<TRight>, Func<TLeft, TRight, TResult>) Runs all observable sequences in parallel and combines their last values.
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, 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.
FromEvent<TEventArgs>(Action<EventHandler<TEventArgs>>, Action<EventHandler<TEventArgs>>) Returns an observable sequence that contains the values of the underlying .NET Framework event.
FromEvent<TEventArgs>(Object, String) Returns an observable sequence that contains the values of the underlying .NET Framework event.
FromEvent<TDelegate, TEventArgs>(Func<EventHandler<TEventArgs>, TDelegate>, Action<TDelegate>, Action<TDelegate>) Returns an observable sequence that contains the values of the underlying .NET Framework event.
Generate<TState, TResult>(TState, Func<TState, Boolean>, Func<TState, TResult>, Func<TState, TState>) 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, TResult>, Func<TState, TState>, IScheduler) Generates an observable sequence by iterating a state from an initial state until the condition fails.
GenerateWithTime<TState, TResult>(TState, Func<TState, Boolean>, Func<TState, TResult>, Func<TState, DateTimeOffset>, Func<TState, TState>) Generates an observable sequence by iterating a state from an initial state until the condition fails.
GenerateWithTime<TState, TResult>(TState, Func<TState, Boolean>, Func<TState, TResult>, Func<TState, TimeSpan>, Func<TState, TState>) Generates an observable sequence by iterating a state from an initial state until the condition fails.
GenerateWithTime<TState, TResult>(TState, Func<TState, Boolean>, Func<TState, TResult>, Func<TState, DateTimeOffset>, Func<TState, TState>, IScheduler) Generates an observable sequence by iterating a state from an initial state until the condition fails.
GenerateWithTime<TState, TResult>(TState, Func<TState, Boolean>, Func<TState, TResult>, Func<TState, TimeSpan>, Func<TState, TState>, 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.
If<TResult> Determines whether an observable collection contains values.
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.
IsEmpty<TSource> Determines whether an observable collection is empty.
Join<TResult>(Plan<TResult>[]) Joins together the results from several patterns.
Join<TResult>(IEnumerable<Plan<TResult>>) Joins together the results from several patterns.
Last<TSource> Returns the last value of an observable sequence.
LastOrDefault<TSource> Returns the last value of an observable sequence, or a default value if no value is found.
Latest<TSource> Samples the most recent value (buffer of size one with consumption) in an observable sequence.
Let<TValue, TResult>(TValue, Func<TValue, IObservable<TResult>>) Binds the source to the parameter without sharing subscription side effects.
Let<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>) Binds the source to the parameter without sharing subscription side effects.
LongCount<TSource> Returns an Int64 value that represents the total number of values 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 System.Decimal.
Max(IObservable<Double>) Returns the maximum value in an observable sequence of System.Double values.
Max(IObservable<Int32>) Returns the maximum value in an observable sequence of System.Int32 values.
Max(IObservable<Int64>) Returns the maximum value in an observable sequence of System.Int64 values.
Max(IObservable<Nullable<Decimal>>) Returns the maximum value in an observable sequence of nullable System.Decimal values.
Max(IObservable<Nullable<Double>>) Returns the maximum value in an observable sequence of nullable System.Double values.
Max(IObservable<Nullable<Int32>>) Returns the maximum value in an observable sequence of nullable System.Int32 values.
Max(IObservable<Nullable<Int64>>) Returns the maximum value in an observable sequence of nullable System.Int64 values.
Max(IObservable<Nullable<Single>>) Returns the maximum value in an observable sequence of System.Float values.
Max(IObservable<Single>) Returns the maximum value in an observable sequence.
Max<TSource>(IObservable<TSource>) Returns the maximum value in an observable sequence.
Max<TSource>(IObservable<TSource>, IComparer<TSource>) Returns the maximum value in an observable sequence as determined by the specified comparer function.
MaxBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>) Returns the element in an observable sequence with the maximum key value.
MaxBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>, IComparer<TKey>) Returns the element in an observable sequence with the maximum key value.
Merge<TSource>(IEnumerable<IObservable<TSource>>) Merges an observable sequence of observable sequences into an observable sequence.
Merge<TSource>(IObservable<IObservable<TSource>>) Merges an observable sequence of observable sequences into an observable sequence.
Merge<TSource>(IObservable<TSource>[]) Merges an observable sequence of observable sequences into an observable sequence.
Merge<TSource>(IEnumerable<IObservable<TSource>>, IScheduler) Merges an observable sequence of observable sequences into an observable sequence.
Merge<TSource>(IObservable<TSource>, IObservable<TSource>) Merges an observable sequence of observable sequences into an observable sequence.
Merge<TSource>(IScheduler, IObservable<TSource>[]) Merges an observable sequence of observable sequences into an observable sequence.
Merge<TSource>(IObservable<TSource>, IObservable<TSource>, IScheduler) Merges an observable sequence of observable sequences into an observable sequence.
Min(IObservable<Decimal>) Returns the minimum value in an observable sequence of System.Decimal values.
Min(IObservable<Double>) Returns the minimum value in an observable sequence of System.Double values.
Min(IObservable<Int32>) Returns the minimum value in an observable sequence of System.Int32 values.
Min(IObservable<Int64>) Returns the minimum value in an observable sequence of System.Int64 values.
Min(IObservable<Nullable<Decimal>>) Returns the minimum value in an observable sequence of nullable System.Decimal values.
Min(IObservable<Nullable<Double>>) Returns the minimum value in an observable sequence of nullable System.Double values.
Min(IObservable<Nullable<Int32>>) Returns the minimum value in an observable sequence of Nullable System.Int32 values.
Min(IObservable<Nullable<Int64>>) Returns the minimum value in an observable sequence of nullable System.Int64 values.
Min(IObservable<Nullable<Single>>) Returns the minimum value in an observable sequence.
Min(IObservable<Single>) Returns the minimum value in an observable sequence.
Min<TSource>(IObservable<TSource>) Returns the minimum value in an observable sequence.
Min<TSource>(IObservable<TSource>, IComparer<TSource>) Returns the minimum value in an observable sequence as determined by the specified comparer function.
MinBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>) Returns the element in an observable sequence with the minimum key value.
MinBy<TSource, TKey>(IObservable<TSource>, Func<TSource, TKey>, IComparer<TKey>) Returns the element in an observable sequence with the minimum key value.
MostRecent<TSource> Samples the most recent value (buffer of size one without consumption) in an observable sequence.
Never<TValue> Returns a non-terminating observable sequence.
Next<TSource> Samples the next value (blocking without buffering) from an observable sequence.
ObserveOn<TSource>(IObservable<TSource>, DispatcherScheduler) Asynchronously notifies observers using the scheduler.
ObserveOn<TSource>(IObservable<TSource>, IScheduler) Asynchronously notifies observers using the scheduler.
ObserveOn<TSource>(IObservable<TSource>, SynchronizationContext) Asynchronously notifies observers on the synchronization context.
ObserveOnDispatcher<TSource> Asynchronously notifies observers using the current dispatcher.
OfType<TResult> Filters values of the given 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.
Prune<TSource>(IObservable<TSource>) Returns a connectable observable sequence that shares a single subscription to the underlying source containing only the last notification.
Prune<TSource>(IObservable<TSource>, IScheduler) Returns a connectable observable sequence that shares a single subscription to the underlying source containing only the last notification.
Prune<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 source containing only the last notification.
Prune<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 source containing only the last notification.
Publish<TSource>(IObservable<TSource>) Returns a connectable observable sequence that shares a single subscription to the underlying source.
Publish<TSource>(IObservable<TSource>, TSource) Returns a connectable observable sequence that shares a single subscription to the underlying source and starts with initialValue.
Publish<TSource>(IObservable<TSource>, TSource, IScheduler) Returns a connectable observable sequence that shares a single subscription to the underlying source 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 source.
Publish<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, TSource) 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 source and starts with initialValue.
Publish<TSource, TResult>(IObservable<TSource>, Func<IObservable<TSource>, IObservable<TResult>>, TSource, 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 source and starts with initialValue.
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.
RemoveTimeInterval<TSource> Removes the timestamp from each value of an observable sequence.
RemoveTimestamp<TSource> Removes the timestamp from each value of an observable sequence.
Repeat<TValue>(TValue) Generates an observable sequence that contains one repeated value.
Repeat<TSource>(IObservable<TSource>) Repeats the observable sequence indefinitely.
Repeat<TValue>(TValue, IScheduler) Generates an observable sequence that contains one repeated value.
Repeat<TValue>(TValue, Int32) Generates an observable sequence that contains one repeated value.
Repeat<TSource>(IObservable<TSource>, Int32) Repeats the observable sequence the specified number of times.
Repeat<TValue>(TValue, Int32, IScheduler) Generates an observable sequence that contains one repeated value.
Replay<TSource>(IObservable<TSource>) Returns a connectable observable sequence that shares a single subscription to the underlying source replaying all notifications.
Replay<TSource>(IObservable<TSource>, IScheduler) Returns a connectable observable sequence that shares a single subscription to the underlying source replaying all notifications.
Replay<TSource>(IObservable<TSource>, Int32) Returns a connectable observable sequence that shares a single subscription to the underlying source replaying bufferSize notifications.
Replay<TSource>(IObservable<TSource>, TimeSpan) Returns a connectable observable sequence that shares a single subscription to the underlying source replaying all notifications within window.
Replay<TSource>(IObservable<TSource>, Int32, IScheduler) Returns a connectable observable sequence that shares a single subscription to the underlying source replaying bufferSize notifications within window.
Replay<TSource>(IObservable<TSource>, Int32, TimeSpan) Returns a connectable observable sequence that shares a single subscription to the underlying source replaying bufferSize notifications within window.
Replay<TSource>(IObservable<TSource>, TimeSpan, IScheduler) Returns a connectable observable sequence that shares a single subscription to the underlying source 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 source 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 source replaying all 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 source replaying all notifications.
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 source replaying bufferSize 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 source 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 source 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 source 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 source 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 source 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 for retryCount times or until it successfully terminates.
Return<TValue>(TValue) Returns an observable sequence that contains a single value.
Return<TValue>(TValue, IScheduler) Returns an observable sequence that contains a single value.
Run<TSource>(IObservable<TSource>) Invokes the observable sequence for its side effects and blocks until the sequence is terminated.
Run<TSource>(IObservable<TSource>, Action<TSource>) Invokes the action for its side effects on each value in the observable sequence and blocks until the sequence is terminated.
Run<TSource>(IObservable<TSource>, IObserver<TSource>) Invokes the action for its side effects on each value in the observable sequence and blocks until the sequence is terminated.
Run<TSource>(IObservable<TSource>, Action<TSource>, Action) Invokes the action for its side effects on each value in the observable sequence and blocks until the sequence is terminated.
Run<TSource>(IObservable<TSource>, Action<TSource>, Action<Exception>) Invokes the action for its side effects on each value in the observable sequence and blocks until the sequence is terminated.
Run<TSource>(IObservable<TSource>, Action<TSource>, Action<Exception>, Action) Invokes the action for its side effects on each value in the observable sequence and blocks until the sequence is terminated.
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.
Scan<TSource>(IObservable<TSource>, Func<TSource, TSource, TSource>) Applies an accumulator function over an observable sequence and returns each intermediate result.
Scan<TSource, TAccumulate>(IObservable<TSource>, TAccumulate, Func<TAccumulate, TSource, TAccumulate>) Applies an accumulator function over an observable sequence and returns each intermediate result. The specified seed value is used as the initial accumulator value.
Scan0<TSource, TAccumulate> Applies an accumulator function over an observable sequence and returns each intermediate result. The specified seed value is prepended to the sequence once a message comes in.
Select<TSource, TResult>(IObservable<TSource>, Func<TSource, TResult>) Projects each value of an observable sequence into a new form.
Select<TSource, TResult>(IObservable<TSource>, Func<TSource, Int32, TResult>) Projects each value of an observable sequence into a new form by incorporating the element's index.
SelectMany<TSource, TResult>(IObservable<TSource>, Func<TSource, IEnumerable<TResult>>) Projects each value 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 value 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 value 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 value of an observable sequence to an observable sequence, flattens the resulting observable sequences into one observable sequence, and invokes a result selector function on each value therein.
SelectMany<TSource, TCollection, TResult>(IObservable<TSource>, Func<TSource, IObservable<TCollection>>, Func<TSource, TCollection, TResult>) Projects each value of an observable sequence to an observable sequence, flattens the resulting observable sequences into one observable sequence, and invokes a result selector function on each value therein.
Single<TSource> Returns the only value of an observable sequence, and throws an exception if there is not exactly one value in the observable sequence.
SingleOrDefault<TSource> Returns the only value of an observable sequence, or a default value if the observable sequence is empty. This method throws an exception if there is more than one value in the observable sequence.
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 values 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> 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 values to an observable sequence.
StartWith<TSource>(IObservable<TSource>, IScheduler, TSource[]) Prepends a sequence values to an observable sequence.
Subscribe<TSource>(IEnumerable<TSource>, IObserver<TSource>) Subscribes an observer to an enumerable sequence. Returns an object that can be used to unsubscribe the observer from the enumerable.
Subscribe<TSource>(IEnumerable<TSource>, IObserver<TSource>, IScheduler) Subscribes an observer to an enumerable sequence. Returns an object that can be used to unsubscribe the observer from the enumerable.
SubscribeOn<TSource>(IObservable<TSource>, DispatcherScheduler) Asynchronously subscribes and unsubscribes observers using the scheduler.
SubscribeOn<TSource>(IObservable<TSource>, IScheduler) Asynchronously subscribes and unsubscribes observers using the scheduler.
SubscribeOn<TSource>(IObservable<TSource>, SynchronizationContext) Asynchronously subscribes and unsubscribes observers on the synchronization context.
SubscribeOnDispatcher<TSource> Asynchronously subscribes and unsubscribes observers using the current dispatcher.
Sum(IObservable<Decimal>) Computes the sum of a sequence of System.Decimal values.
Sum(IObservable<Double>) Computes the sum of a sequence of System.Double values.
Sum(IObservable<Int32>) Computes the sum of a sequence of System.Int32 values.
Sum(IObservable<Int64>) Computes the sum of a sequence of System.Int64 values.
Sum(IObservable<Nullable<Decimal>>) Computes the sum of a sequence of nullable System.Decimal values.
Sum(IObservable<Nullable<Double>>) Computes the sum of a sequence of nullable System.Double values.
Sum(IObservable<Nullable<Int32>>) Computes the sum of a sequence of nullable System.Int32 values.
Sum(IObservable<Nullable<Int64>>) Computes the sum of a sequence of nullable System.Int64 values.
Sum(IObservable<Nullable<Single>>) Computes the sum of a sequence of nullable System.Float values.
Sum(IObservable<Single>) Computes the sum of a sequence of System.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>(IObservable<TSource>, Int32) Returns a specified number of contiguous values from the start of an observable sequence.
Take<TSource>(IObservable<TSource>, Int32, IScheduler) Returns a specified number of contiguous values from the start of an observable sequence.
TakeLast<TSource> Returns a specified number of contiguous values 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> 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 values from an observable sequence that are followed by another value before the specified time span.
Throttle<TSource>(IObservable<TSource>, TimeSpan, IScheduler) Ignores values from an observable sequence that are followed by another value before the specified time span.
Throw<TValue>(Exception) Returns an observable sequence that terminates with an exception.
Throw<TValue>(Exception, IScheduler) Returns an observable sequence that terminates with an exception.
TimeInterval<TSource>(IObservable<TSource>) Records the time interval for each value of an observable sequence.
TimeInterval<TSource>(IObservable<TSource>, IScheduler) Records the time interval for each value of an observable sequence.
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 a TimeoutException if dueTime elapses.
Timeout<TSource>(IObservable<TSource>, DateTimeOffset, IScheduler) Returns either the observable sequence or a TimeoutException if dueTime elapses.
Timeout<TSource>(IObservable<TSource>, DateTimeOffset, 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 a 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>, 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 dueTime.
Timer(TimeSpan) Returns an observable sequence that produces a value after the dueTime has elapsed.
Timer(DateTimeOffset, IScheduler) Returns an observable sequence that produces a value after the dueTime has elapsed.
Timer(DateTimeOffset, TimeSpan) Returns an observable sequence that produces a value at dueTime and then after each period.
Timer(TimeSpan, IScheduler) Returns an observable sequence that produces a value after the dueTime has elapsed.
Timer(TimeSpan, TimeSpan) Returns an observable sequence that produces a value after dueTime has elapsed and then after each period.
Timer(DateTimeOffset, TimeSpan, IScheduler) Returns an observable sequence that produces a value at dueTime and then after each period.
Timer(TimeSpan, TimeSpan, IScheduler) Returns an observable sequence that produces a value after dueTime has elapsed and then after each period.
Timestamp<TSource>(IObservable<TSource>) Records the timestamp for each value of an observable sequence.
Timestamp<TSource>(IObservable<TSource>, IScheduler) Records the timestamp for each value of an observable sequence.
ToAsync(Action) Converts the action into an asynchronous function.
ToAsync(Action, IScheduler) Converts the action into an asynchronous function.
ToAsync<TSource>(Action<TSource>) Converts the action into an asynchronous function.
ToAsync<TResult>(Func<TResult>) Converts the function into an asynchronous function.
ToAsync<TSource>(Action<TSource>, IScheduler) Converts the action into an asynchronous function.
ToAsync<TResult>(Func<TResult>, IScheduler) Converts the function into an asynchronous function.
ToAsync<T1, T2>(Action<T1, T2>) Converts the action 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 action 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 action 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 action 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 action 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 action 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, TResult>(Func<T1, T2, T3, T4, TResult>) 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.
ToEnumerable<TSource> Converts an observable sequence to an enumerable sequence.
ToObservable<TSource>(IEnumerable<TSource>) Converts an enumerable sequence to an observable sequence.
ToObservable<TSource>(IEnumerable<TSource>, IScheduler) Converts an enumerable sequence to an observable sequence.
Using<TSource, TResource> Retrieves resource from resourceSelector for use in resourceUsage and disposes the resource once the resulting observable sequence terminates.
Where<TSource>(IObservable<TSource>, Func<TSource, Boolean>) Filters the values of an observable sequence based on a predicate.
Where<TSource>(IObservable<TSource>, Func<TSource, Int32, Boolean>) Filters the values of an observable sequence based on a predicate by incorporating the element's index.
While<TSource> Repeats source as long as condition holds.
Zip<TLeft, TRight, TResult>(IObservable<TLeft>, IEnumerable<TRight>, Func<TLeft, TRight, TResult>) Merges an observable sequence and an enumerable sequence into one observable sequence by using the selector function.
Zip<TLeft, TRight, TResult>(IObservable<TLeft>, IObservable<TRight>, Func<TLeft, TRight, TResult>) Merges two observable sequences into one observable sequence by using the selector function.
Top