IObservable<T> Interface
March 22, 2012
Defines a provider for push-based notification.
Assembly: System.Observable (in System.Observable.dll)
The IObservable<T> type exposes the following members.
| Name | Description | |
|---|---|---|
|
Aggregate<TSource>(Func<TSource, TSource, TSource>) | Overloaded. Applies an accumulator function over an observable sequence. The specified seed value is used as the initial accumulator value. (Defined by Observable.) |
|
|
Aggregate<TSource, TAccumulate>(TAccumulate, Func<TAccumulate, TSource, TAccumulate>) | Overloaded. Applies an accumulator function over an observable sequence. The specified seed value is used as the initial accumulator value. (Defined by Observable.) |
|
|
All<TSource> | Determines whether all values of an observable sequence satisfy a condition. (Defined by Observable.) |
|
|
Amb<TSource> | Returns the observable sequence that reacts first. (Defined by Observable.) |
|
|
And<TLeft, TRight> | Matches when both observable sequences have an available value. (Defined by Observable.) |
|
|
Any<TSource>() | Overloaded. Determines whether an observable sequence contains any values. (Defined by Observable.) |
|
|
Any<TSource>(Func<TSource, Boolean>) | Overloaded. Determines whether an observable sequence contains any values. (Defined by Observable.) |
|
|
AsObservable<TSource> | Hides the identity of an observable sequence. (Defined by Observable.) |
|
|
BufferWithCount<TSource>(Int32) | Overloaded. Projects each value of an observable sequence into a buffer. (Defined by Observable.) |
|
|
BufferWithCount<TSource>(Int32, Int32) | Overloaded. Projects each value of an observable sequence into a buffer. (Defined by Observable.) |
|
|
BufferWithTime<TSource>(TimeSpan) | Overloaded. Projects each value of an observable sequence into a buffer. (Defined by Observable.) |
|
|
BufferWithTime<TSource>(TimeSpan, IScheduler) | Overloaded. Projects each value of an observable sequence into a buffer. (Defined by Observable.) |
|
|
BufferWithTime<TSource>(TimeSpan, TimeSpan) | Overloaded. Projects each value of an observable sequence into a buffer. (Defined by Observable.) |
|
|
BufferWithTime<TSource>(TimeSpan, TimeSpan, IScheduler) | Overloaded. Projects each value of an observable sequence into a buffer. (Defined by Observable.) |
|
|
BufferWithTimeOrCount<TSource>(TimeSpan, Int32) | Overloaded. 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. (Defined by Observable.) |
|
|
BufferWithTimeOrCount<TSource>(TimeSpan, Int32, IScheduler) | Overloaded. 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. (Defined by Observable.) |
|
|
Catch<TSource>(IObservable<TSource>) | Overloaded. Continues an observable sequence that is terminated by an exception with the next observable sequence. (Defined by Observable.) |
|
|
Catch<TSource, TException>(Func<TException, IObservable<TSource>>) | Overloaded. Continues an observable sequence that is terminated by an exception with the next observable sequence. (Defined by Observable.) |
|
|
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. (Defined by Observable.) |
|
|
Concat<TSource> | Concatenates two observable sequences. (Defined by Observable.) |
|
|
Contains<TSource>(TSource) | Overloaded. Determines whether an observable sequence contains a specified value by using the default comparer. (Defined by Observable.) |
|
|
Contains<TSource>(TSource, IEqualityComparer<TSource>) | Overloaded. Determines whether an observable sequence contains a specified value by using the specified comparer. (Defined by Observable.) |
|
|
Count<TSource> | Returns the number of elements in an observable sequence. (Defined by Observable.) |
|
|
Delay<TSource>(TimeSpan) | Overloaded. Time-shifts the observable sequence by the specified time span. The relative time intervals between the values are preserved. (Defined by Observable.) |
|
|
Delay<TSource>(DateTimeOffset) | Overloaded. Time-shifts the observable sequence by the specified time span. The relative time intervals between the values are preserved. (Defined by Observable.) |
|
|
Delay<TSource>(TimeSpan, IScheduler) | Overloaded. Time-shifts the observable sequence by the specified time span. The relative time intervals between the values are preserved. (Defined by Observable.) |
|
|
Delay<TSource>(DateTimeOffset, IScheduler) | Overloaded. Time-shifts the observable sequence by the specified time span. The relative time intervals between the values are preserved. (Defined by Observable.) |
|
|
DistinctUntilChanged<TSource>() | Overloaded. Returns an observable sequence that contains only distinct contiguous values. (Defined by Observable.) |
|
|
DistinctUntilChanged<TSource>(IEqualityComparer<TSource>) | Overloaded. Returns an observable sequence that contains only distinct contiguous values according to the comparer. (Defined by Observable.) |
|
|
DistinctUntilChanged<TSource, TKey>(Func<TSource, TKey>) | Overloaded. Returns an observable sequence that contains only distinct contiguous values according to the specified key selector function. (Defined by Observable.) |
|
|
DistinctUntilChanged<TSource, TKey>(Func<TSource, TKey>, IEqualityComparer<TKey>) | Overloaded. Returns an observable sequence that contains only distinct contiguous values according to the specified key selector function and comparer. (Defined by Observable.) |
|
|
Do<TSource>(Action<TSource>) | Overloaded. Invokes the action for its side effects on each value in the observable sequence. (Defined by Observable.) |
|
|
Do<TSource>(IObserver<TSource>) | Overloaded. Invokes the action for its side effects on each value in the observable sequence. (Defined by Observable.) |
|
|
Do<TSource>(Action<TSource>, Action) | Overloaded. Invokes the action for its side effects on each value in the observable sequence. (Defined by Observable.) |
|
|
Do<TSource>(Action<TSource>, Action<Exception>) | Overloaded. Invokes the action for its side effects on each value in the observable sequence. (Defined by Observable.) |
|
|
Do<TSource>(Action<TSource>, Action<Exception>, Action) | Overloaded. Invokes the action for its side effects on each value in the observable sequence. (Defined by Observable.) |
|
|
Finally<TSource> | Invokes finallyAction after the source observable sequence terminates normally or by an exception. (Defined by Observable.) |
|
|
First<TSource> | Returns the first value of an observable sequence. (Defined by Observable.) |
|
|
FirstOrDefault<TSource> | Returns the first value of an observable sequence, or a default value if no value is found. (Defined by Observable.) |
|
|
ForkJoin<TLeft, TRight, TResult> | Runs all observable sequences in parallel and combines their last values. (Defined by Observable.) |
|
|
GetEnumerator<TSource> | Returns an enumerator that enumerates all values of the observable sequence. (Defined by Observable.) |
|
|
GroupBy<TSource, TKey>(Func<TSource, TKey>) | Overloaded. Groups the elements of an observable sequence according to a specified key selector function. (Defined by Observable.) |
|
|
GroupBy<TSource, TKey>(Func<TSource, TKey>, IEqualityComparer<TKey>) | Overloaded. Groups the elements of an observable sequence according to a specified key selector function and comparer. (Defined by Observable.) |
|
|
GroupBy<TSource, TKey, TElement>(Func<TSource, TKey>, Func<TSource, TElement>) | Overloaded. Groups the elements of an observable sequence and selects the resulting elements by using a specified function. (Defined by Observable.) |
|
|
GroupBy<TSource, TKey, TElement>(Func<TSource, TKey>, Func<TSource, TElement>, IEqualityComparer<TKey>) | Overloaded. 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. (Defined by Observable.) |
|
|
IsEmpty<TSource> | Determines whether an observable collection is empty. (Defined by Observable.) |
|
|
Last<TSource> | Returns the last value of an observable sequence. (Defined by Observable.) |
|
|
LastOrDefault<TSource> | Returns the last value of an observable sequence, or a default value if no value is found. (Defined by Observable.) |
|
|
Latest<TSource> | Samples the most recent value (buffer of size one with consumption) in an observable sequence. (Defined by Observable.) |
|
|
Let<TSource, TResult> | Binds the source to the parameter without sharing subscription side effects. (Defined by Observable.) |
|
|
LongCount<TSource> | Returns an Int64 value that represents the total number of values in an observable sequence. (Defined by Observable.) |
|
|
Materialize<TSource> | Materializes the implicit notifications of an observable sequence as explicit notification values. (Defined by Observable.) |
|
|
Max<TSource>() | Overloaded. Returns the maximum value in an observable sequence. (Defined by Observable.) |
|
|
Max<TSource>(IComparer<TSource>) | Overloaded. Returns the maximum value in an observable sequence as determined by the specified comparer function. (Defined by Observable.) |
|
|
MaxBy<TSource, TKey>(Func<TSource, TKey>) | Overloaded. Returns the element in an observable sequence with the maximum key value. (Defined by Observable.) |
|
|
MaxBy<TSource, TKey>(Func<TSource, TKey>, IComparer<TKey>) | Overloaded. Returns the element in an observable sequence with the maximum key value. (Defined by Observable.) |
|
|
Merge<TSource>(IObservable<TSource>) | Overloaded. Merges an observable sequence of observable sequences into an observable sequence. (Defined by Observable.) |
|
|
Merge<TSource>(IObservable<TSource>, IScheduler) | Overloaded. Merges an observable sequence of observable sequences into an observable sequence. (Defined by Observable.) |
|
|
Min<TSource>() | Overloaded. Returns the minimum value in an observable sequence. (Defined by Observable.) |
|
|
Min<TSource>(IComparer<TSource>) | Overloaded. Returns the minimum value in an observable sequence as determined by the specified comparer function. (Defined by Observable.) |
|
|
MinBy<TSource, TKey>(Func<TSource, TKey>) | Overloaded. Returns the element in an observable sequence with the minimum key value. (Defined by Observable.) |
|
|
MinBy<TSource, TKey>(Func<TSource, TKey>, IComparer<TKey>) | Overloaded. Returns the element in an observable sequence with the minimum key value. (Defined by Observable.) |
|
|
MostRecent<TSource> | Samples the most recent value (buffer of size one without consumption) in an observable sequence. (Defined by Observable.) |
|
|
Next<TSource> | Samples the next value (blocking without buffering) from an observable sequence. (Defined by Observable.) |
|
|
ObserveOn<TSource>(Dispatcher) | Overloaded. Asynchronously notify observers using the dispatcher. (Defined by DispatcherObservableExtensions.) |
|
|
ObserveOn<TSource>(SynchronizationContext) | Overloaded. Asynchronously notifies observers on the synchronization context. (Defined by Observable.) |
|
|
ObserveOn<TSource>(DispatcherScheduler) | Overloaded. Asynchronously notifies observers using the scheduler. (Defined by Observable.) |
|
|
ObserveOn<TSource>(IScheduler) | Overloaded. Asynchronously notifies observers using the scheduler. (Defined by Observable.) |
|
|
ObserveOnDispatcher<TSource> | Asynchronously notifies observers using the current dispatcher. (Defined by Observable.) |
|
|
OnErrorResumeNext<TSource> | Continues an observable sequence that is terminated normally or by an exception with the next observable sequence. (Defined by Observable.) |
|
|
Prune<TSource>() | Overloaded. Returns a connectable observable sequence that shares a single subscription to the underlying source containing only the last notification. (Defined by Observable.) |
|
|
Prune<TSource>(IScheduler) | Overloaded. Returns a connectable observable sequence that shares a single subscription to the underlying source containing only the last notification. (Defined by Observable.) |
|
|
Prune<TSource, TResult>(Func<IObservable<TSource>, IObservable<TResult>>) | Overloaded. 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. (Defined by Observable.) |
|
|
Prune<TSource, TResult>(Func<IObservable<TSource>, IObservable<TResult>>, IScheduler) | Overloaded. 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. (Defined by Observable.) |
|
|
Publish<TSource>() | Overloaded. Returns a connectable observable sequence that shares a single subscription to the underlying source. (Defined by Observable.) |
|
|
Publish<TSource>(TSource) | Overloaded. Returns a connectable observable sequence that shares a single subscription to the underlying source and starts with initialValue. (Defined by Observable.) |
|
|
Publish<TSource>(TSource, IScheduler) | Overloaded. Returns a connectable observable sequence that shares a single subscription to the underlying source and starts with initialValue. (Defined by Observable.) |
|
|
Publish<TSource, TResult>(Func<IObservable<TSource>, IObservable<TResult>>) | Overloaded. 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. (Defined by Observable.) |
|
|
Publish<TSource, TResult>(Func<IObservable<TSource>, IObservable<TResult>>, TSource) | Overloaded. 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. (Defined by Observable.) |
|
|
Publish<TSource, TResult>(Func<IObservable<TSource>, IObservable<TResult>>, TSource, IScheduler) | Overloaded. 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. (Defined by Observable.) |
|
|
Repeat<TSource>() | Overloaded. Repeats the observable sequence indefinitely. (Defined by Observable.) |
|
|
Repeat<TSource>(Int32) | Overloaded. Repeats the observable sequence the specified number of times. (Defined by Observable.) |
|
|
Replay<TSource>() | Overloaded. Returns a connectable observable sequence that shares a single subscription to the underlying source replaying all notifications. (Defined by Observable.) |
|
|
Replay<TSource>(TimeSpan) | Overloaded. Returns a connectable observable sequence that shares a single subscription to the underlying source replaying all notifications within window. (Defined by Observable.) |
|
|
Replay<TSource>(Int32) | Overloaded. Returns a connectable observable sequence that shares a single subscription to the underlying source replaying bufferSize notifications. (Defined by Observable.) |
|
|
Replay<TSource>(IScheduler) | Overloaded. Returns a connectable observable sequence that shares a single subscription to the underlying source replaying all notifications. (Defined by Observable.) |
|
|
Replay<TSource>(TimeSpan, IScheduler) | Overloaded. Returns a connectable observable sequence that shares a single subscription to the underlying source replaying all notifications within window. (Defined by Observable.) |
|
|
Replay<TSource>(Int32, IScheduler) | Overloaded. Returns a connectable observable sequence that shares a single subscription to the underlying source replaying bufferSize notifications within window. (Defined by Observable.) |
|
|
Replay<TSource>(Int32, TimeSpan) | Overloaded. Returns a connectable observable sequence that shares a single subscription to the underlying source replaying bufferSize notifications within window. (Defined by Observable.) |
|
|
Replay<TSource>(Int32, TimeSpan, IScheduler) | Overloaded. Returns a connectable observable sequence that shares a single subscription to the underlying source replaying bufferSize notifications within window. (Defined by Observable.) |
|
|
Replay<TSource, TResult>(Func<IObservable<TSource>, IObservable<TResult>>) | Overloaded. 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. (Defined by Observable.) |
|
|
Replay<TSource, TResult>(Func<IObservable<TSource>, IObservable<TResult>>, IScheduler) | Overloaded. 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. (Defined by Observable.) |
|
|
Replay<TSource, TResult>(Func<IObservable<TSource>, IObservable<TResult>>, TimeSpan) | Overloaded. 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. (Defined by Observable.) |
|
|
Replay<TSource, TResult>(Func<IObservable<TSource>, IObservable<TResult>>, Int32) | Overloaded. 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. (Defined by Observable.) |
|
|
Replay<TSource, TResult>(Func<IObservable<TSource>, IObservable<TResult>>, TimeSpan, IScheduler) | Overloaded. 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. (Defined by Observable.) |
|
|
Replay<TSource, TResult>(Func<IObservable<TSource>, IObservable<TResult>>, Int32, IScheduler) | Overloaded. 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. (Defined by Observable.) |
|
|
Replay<TSource, TResult>(Func<IObservable<TSource>, IObservable<TResult>>, Int32, TimeSpan) | Overloaded. 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. (Defined by Observable.) |
|
|
Replay<TSource, TResult>(Func<IObservable<TSource>, IObservable<TResult>>, Int32, TimeSpan, IScheduler) | Overloaded. 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. (Defined by Observable.) |
|
|
Retry<TSource>() | Overloaded. Repeats the source observable sequence until it successfully terminates. (Defined by Observable.) |
|
|
Retry<TSource>(Int32) | Overloaded. Repeats the source observable sequence for retryCount times or until it successfully terminates. (Defined by Observable.) |
|
|
Run<TSource>() | Overloaded. Invokes the observable sequence for its side effects and blocks until the sequence is terminated. (Defined by Observable.) |
|
|
Run<TSource>(Action<TSource>) | Overloaded. Invokes the action for its side effects on each value in the observable sequence and blocks until the sequence is terminated. (Defined by Observable.) |
|
|
Run<TSource>(IObserver<TSource>) | Overloaded. Invokes the action for its side effects on each value in the observable sequence and blocks until the sequence is terminated. (Defined by Observable.) |
|
|
Run<TSource>(Action<TSource>, Action) | Overloaded. Invokes the action for its side effects on each value in the observable sequence and blocks until the sequence is terminated. (Defined by Observable.) |
|
|
Run<TSource>(Action<TSource>, Action<Exception>) | Overloaded. Invokes the action for its side effects on each value in the observable sequence and blocks until the sequence is terminated. (Defined by Observable.) |
|
|
Run<TSource>(Action<TSource>, Action<Exception>, Action) | Overloaded. Invokes the action for its side effects on each value in the observable sequence and blocks until the sequence is terminated. (Defined by Observable.) |
|
|
Sample<TSource>(TimeSpan) | Overloaded. Samples the observable sequence at each interval. (Defined by Observable.) |
|
|
Sample<TSource>(TimeSpan, IScheduler) | Overloaded. Samples the observable sequence at each interval. (Defined by Observable.) |
|
|
Scan<TSource>(Func<TSource, TSource, TSource>) | Overloaded. Applies an accumulator function over an observable sequence and returns each intermediate result. (Defined by Observable.) |
|
|
Scan<TSource, TAccumulate>(TAccumulate, Func<TAccumulate, TSource, TAccumulate>) | Overloaded. Applies an accumulator function over an observable sequence and returns each intermediate result. The specified seed value is used as the initial accumulator value. (Defined by Observable.) |
|
|
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. (Defined by Observable.) |
|
|
Select<TSource, TResult>(Func<TSource, TResult>) | Overloaded. Projects each value of an observable sequence into a new form. (Defined by Observable.) |
|
|
Select<TSource, TResult>(Func<TSource, Int32, TResult>) | Overloaded. Projects each value of an observable sequence into a new form by incorporating the element's index. (Defined by Observable.) |
|
|
SelectMany<TSource, TResult>(Func<TSource, IEnumerable<TResult>>) | Overloaded. Projects each value of an observable sequence to an observable sequence and flattens the resulting observable sequences into one observable sequence. (Defined by Observable.) |
|
|
SelectMany<TSource, TOther>(IObservable<TOther>) | Overloaded. Projects each value of an observable sequence to an observable sequence and flattens the resulting observable sequences into one observable sequence. (Defined by Observable.) |
|
|
SelectMany<TSource, TResult>(Func<TSource, IObservable<TResult>>) | Overloaded. Projects each value of an observable sequence to an observable sequence and flattens the resulting observable sequences into one observable sequence. (Defined by Observable.) |
|
|
SelectMany<TSource, TResult>(Func<TSource, IObservable<TResult>>, Func<Exception, IObservable<TResult>>, Func<IObservable<TResult>>) | Overloaded. 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. (Defined by Observable.) |
|
|
SelectMany<TSource, TCollection, TResult>(Func<TSource, IObservable<TCollection>>, Func<TSource, TCollection, TResult>) | Overloaded. 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. (Defined by Observable.) |
|
|
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. (Defined by Observable.) |
|
|
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. (Defined by Observable.) |
|
|
Skip<TSource> | Bypasses a specified number of values in an observable sequence and then returns the remaining values. (Defined by Observable.) |
|
|
SkipLast<TSource> | Bypasses a specified number of values at the end of an observable sequence. (Defined by Observable.) |
|
|
SkipUntil<TSource, TOther> | Returns the values from the source observable sequence only after the other observable sequence produces a value. (Defined by Observable.) |
|
|
SkipWhile<TSource> | Bypasses values in an observable sequence as long as a specified condition is true and then returns the remaining values. (Defined by Observable.) |
|
|
StartWith<TSource>(TSource[]) | Overloaded. Prepends a sequence values to an observable sequence. (Defined by Observable.) |
|
|
StartWith<TSource>(IScheduler, TSource[]) | Overloaded. Prepends a sequence values to an observable sequence. (Defined by Observable.) |
|
|
Subscribe<TSource>() | Overloaded. Evaluates the observable sequence. (Defined by ObservableExtensions.) |
|
|
Subscribe<TSource>(Action<TSource>) | Overloaded. Subscribes a value handler to an observable sequence. (Defined by ObservableExtensions.) |
|
|
Subscribe<TSource>(Action<TSource>, Action<Exception>) | Overloaded. Subscribes a value handler and an exception handler to an observable sequence. (Defined by ObservableExtensions.) |
|
|
Subscribe<TSource>(Action<TSource>, Action) | Overloaded. Subscribes a value handler and a completion handler to an observable sequence. (Defined by ObservableExtensions.) |
|
|
Subscribe<TSource>(Action<TSource>, Action<Exception>, Action) | Overloaded. Subscribes a value handler, an exception handler, and a completion handler to an observable sequence. (Defined by ObservableExtensions.) |
|
|
SubscribeOn<TSource>(Dispatcher) | Overloaded. Asynchronously subscribes and unsubscribes observers using the dispatcher. (Defined by DispatcherObservableExtensions.) |
|
|
SubscribeOn<TSource>(SynchronizationContext) | Overloaded. Asynchronously subscribes and unsubscribes observers on the synchronization context. (Defined by Observable.) |
|
|
SubscribeOn<TSource>(DispatcherScheduler) | Overloaded. Asynchronously subscribes and unsubscribes observers using the scheduler. (Defined by Observable.) |
|
|
SubscribeOn<TSource>(IScheduler) | Overloaded. Asynchronously subscribes and unsubscribes observers using the scheduler. (Defined by Observable.) |
|
|
SubscribeOnDispatcher<TSource> | Asynchronously subscribes and unsubscribes observers using the current dispatcher. (Defined by Observable.) |
|
|
Synchronize<TSource>() | Overloaded. Synchronizes the observable sequence. (Defined by Observable.) |
|
|
Synchronize<TSource>(Object) | Overloaded. Synchronizes the observable sequence. (Defined by Observable.) |
|
|
Take<TSource>(Int32) | Overloaded. Returns a specified number of contiguous values from the start of an observable sequence. (Defined by Observable.) |
|
|
Take<TSource>(Int32, IScheduler) | Overloaded. Returns a specified number of contiguous values from the start of an observable sequence. (Defined by Observable.) |
|
|
TakeLast<TSource> | Returns a specified number of contiguous values from the end of an observable sequence. (Defined by Observable.) |
|
|
TakeUntil<TSource, TOther> | Returns the values from the source observable sequence until the other observable sequence produces a value. (Defined by Observable.) |
|
|
TakeWhile<TSource> | Returns values from an observable sequence as long as a specified condition is true, and then skips the remaining values. (Defined by Observable.) |
|
|
Then<TSource, TResult> | Matches when the observable sequence has an available value and projects the value. (Defined by Observable.) |
|
|
Throttle<TSource>(TimeSpan) | Overloaded. Ignores values from an observable sequence that are followed by another value before the specified time span. (Defined by Observable.) |
|
|
Throttle<TSource>(TimeSpan, IScheduler) | Overloaded. Ignores values from an observable sequence that are followed by another value before the specified time span. (Defined by Observable.) |
|
|
TimeInterval<TSource>() | Overloaded. Records the time interval for each value of an observable sequence. (Defined by Observable.) |
|
|
TimeInterval<TSource>(IScheduler) | Overloaded. Records the time interval for each value of an observable sequence. (Defined by Observable.) |
|
|
Timeout<TSource>(TimeSpan) | Overloaded. Returns either the observable sequence or a TimeoutException if dueTime elapses. (Defined by Observable.) |
|
|
Timeout<TSource>(DateTimeOffset) | Overloaded. Returns either the observable sequence or a TimeoutException if dueTime elapses. (Defined by Observable.) |
|
|
Timeout<TSource>(TimeSpan, IObservable<TSource>) | Overloaded. Returns the source observable sequence or the other observable sequence if dueTime elapses. (Defined by Observable.) |
|
|
Timeout<TSource>(DateTimeOffset, IObservable<TSource>) | Overloaded. Returns the source observable sequence or the other observable sequence if dueTime elapses. (Defined by Observable.) |
|
|
Timeout<TSource>(TimeSpan, IScheduler) | Overloaded. Returns either the observable sequence or a TimeoutException if dueTime elapses. (Defined by Observable.) |
|
|
Timeout<TSource>(DateTimeOffset, IScheduler) | Overloaded. Returns either the observable sequence or a TimeoutException if dueTime elapses. (Defined by Observable.) |
|
|
Timeout<TSource>(TimeSpan, IObservable<TSource>, IScheduler) | Overloaded. Returns the source observable sequence or the other observable sequence if dueTime elapses. (Defined by Observable.) |
|
|
Timeout<TSource>(DateTimeOffset, IObservable<TSource>, IScheduler) | Overloaded. Returns the source observable sequence or the other observable sequence if dueTime elapses. (Defined by Observable.) |
|
|
Timestamp<TSource>() | Overloaded. Records the timestamp for each value of an observable sequence. (Defined by Observable.) |
|
|
Timestamp<TSource>(IScheduler) | Overloaded. Records the timestamp for each value of an observable sequence. (Defined by Observable.) |
|
|
ToEnumerable<TSource> | Converts an observable sequence to an enumerable sequence. (Defined by Observable.) |
|
|
Where<TSource>(Func<TSource, Boolean>) | Overloaded. Filters the values of an observable sequence based on a predicate. (Defined by Observable.) |
|
|
Where<TSource>(Func<TSource, Int32, Boolean>) | Overloaded. Filters the values of an observable sequence based on a predicate by incorporating the element's index. (Defined by Observable.) |
|
|
Zip<TLeft, TRight, TResult>(IEnumerable<TRight>, Func<TLeft, TRight, TResult>) | Overloaded. Merges an observable sequence and an enumerable sequence into one observable sequence by using the selector function. (Defined by Observable.) |
|
|
Zip<TLeft, TRight, TResult>(IObservable<TRight>, Func<TLeft, TRight, TResult>) | Overloaded. Merges two observable sequences into one observable sequence by using the selector function. (Defined by Observable.) |
Provides an observable object mechanism to support push-style iteration over an observable sequence for publish/subscribe event processing.
The IObserver<T> and IObservable<T> interfaces provide a generalized mechanism for push-based notification, also known as the observer design pattern. The IObservable<T> interface represents the class that sends notifications (the provider); the IObserver<T> interface represents the class that receives them (the observer). T represents the class that provides the notification information.
An IObserver<T> implementation arranges to receive notifications from a provider (an IObservable<T> implementation) by passing an instance of itself to the provider's IObservable<T>.Subscribe method. This method returns an IDisposable object that can be used to unsubscribe the observer before the provider finishes sending notifications.
The IObserver<T> interface defines the following three methods that the observer must implement:
-
The OnNext method, which is typically called by the provider to supply the observer with new data or state information.
-
The OnError method, which is typically called by the provider to indicate that data is unavailable, inaccessible, or corrupted, or that the provider has experienced some other error condition.
-
The OnCompleted method, which is typically called by the provider to indicate that it has finished sending notifications to observers.
