IConnectableObservable<T> Interface

March 22, 2012

Represents an observable that can be connected and disconnected.

Namespace:  Microsoft.Phone.Reactive
Assembly:  Microsoft.Phone.Reactive (in Microsoft.Phone.Reactive.dll)

public interface IConnectableObservable<T> : IObservable<T>

Type Parameters

T

The IConnectableObservable<T> type exposes the following members.

  NameDescription
Public methodConnectConnects the observable.
Public methodSubscribeSubscribes observer to receive notifications. (Inherited from IObservable<T>.)
Top

  NameDescription
Public Extension MethodAggregate<T>(Func<T, T, T>)Overloaded. Applies an accumulator function over an observable sequence. The specified seed value is used as the initial accumulator value. (Defined by Observable.)
Public Extension MethodAggregate<T, TAccumulate>(TAccumulate, Func<TAccumulate, T, TAccumulate>)Overloaded. Applies an accumulator function over an observable sequence. The specified seed value is used as the initial accumulator value. (Defined by Observable.)
Public Extension MethodAll<T>Determines whether all values of an observable sequence satisfy a condition. (Defined by Observable.)
Public Extension MethodAmb<T>Returns the observable sequence that reacts first. (Defined by Observable.)
Public Extension MethodAnd<T, TRight>Matches when both observable sequences have an available value. (Defined by Observable.)
Public Extension MethodAny<T>()Overloaded. Determines whether an observable sequence contains any values. (Defined by Observable.)
Public Extension MethodAny<T>(Func<T, Boolean>)Overloaded. Determines whether an observable sequence contains any values. (Defined by Observable.)
Public Extension MethodAsObservable<T>Hides the identity of an observable sequence. (Defined by Observable.)
Public Extension MethodBufferWithCount<T>(Int32)Overloaded. Projects each value of an observable sequence into a buffer. (Defined by Observable.)
Public Extension MethodBufferWithCount<T>(Int32, Int32)Overloaded. Projects each value of an observable sequence into a buffer. (Defined by Observable.)
Public Extension MethodBufferWithTime<T>(TimeSpan)Overloaded. Projects each value of an observable sequence into a buffer. (Defined by Observable.)
Public Extension MethodBufferWithTime<T>(TimeSpan, IScheduler)Overloaded. Projects each value of an observable sequence into a buffer. (Defined by Observable.)
Public Extension MethodBufferWithTime<T>(TimeSpan, TimeSpan)Overloaded. Projects each value of an observable sequence into a buffer. (Defined by Observable.)
Public Extension MethodBufferWithTime<T>(TimeSpan, TimeSpan, IScheduler)Overloaded. Projects each value of an observable sequence into a buffer. (Defined by Observable.)
Public Extension MethodBufferWithTimeOrCount<T>(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.)
Public Extension MethodBufferWithTimeOrCount<T>(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.)
Public Extension MethodCatch<T>(IObservable<T>)Overloaded. Continues an observable sequence that is terminated by an exception with the next observable sequence. (Defined by Observable.)
Public Extension MethodCatch<T, TException>(Func<TException, IObservable<T>>)Overloaded. Continues an observable sequence that is terminated by an exception with the next observable sequence. (Defined by Observable.)
Public Extension MethodCombineLatest<T, 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.)
Public Extension MethodConcat<T>Concatenates two observable sequences. (Defined by Observable.)
Public Extension MethodContains<T>(T)Overloaded. Determines whether an observable sequence contains a specified value by using the default comparer. (Defined by Observable.)
Public Extension MethodContains<T>(T, IEqualityComparer<T>)Overloaded. Determines whether an observable sequence contains a specified value by using the specified comparer. (Defined by Observable.)
Public Extension MethodCount<T>Returns the number of elements in an observable sequence. (Defined by Observable.)
Public Extension MethodDelay<T>(TimeSpan)Overloaded. Time-shifts the observable sequence by the specified time span. The relative time intervals between the values are preserved. (Defined by Observable.)
Public Extension MethodDelay<T>(DateTimeOffset)Overloaded. Time-shifts the observable sequence by the specified time span. The relative time intervals between the values are preserved. (Defined by Observable.)
Public Extension MethodDelay<T>(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.)
Public Extension MethodDelay<T>(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.)
Public Extension MethodDistinctUntilChanged<T>()Overloaded. Returns an observable sequence that contains only distinct contiguous values. (Defined by Observable.)
Public Extension MethodDistinctUntilChanged<T>(IEqualityComparer<T>)Overloaded. Returns an observable sequence that contains only distinct contiguous values according to the comparer. (Defined by Observable.)
Public Extension MethodDistinctUntilChanged<T, TKey>(Func<T, TKey>)Overloaded. Returns an observable sequence that contains only distinct contiguous values according to the specified key selector function. (Defined by Observable.)
Public Extension MethodDistinctUntilChanged<T, TKey>(Func<T, 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.)
Public Extension MethodDo<T>(Action<T>)Overloaded. Invokes the action for its side effects on each value in the observable sequence. (Defined by Observable.)
Public Extension MethodDo<T>(IObserver<T>)Overloaded. Invokes the action for its side effects on each value in the observable sequence. (Defined by Observable.)
Public Extension MethodDo<T>(Action<T>, Action)Overloaded. Invokes the action for its side effects on each value in the observable sequence. (Defined by Observable.)
Public Extension MethodDo<T>(Action<T>, Action<Exception>)Overloaded. Invokes the action for its side effects on each value in the observable sequence. (Defined by Observable.)
Public Extension MethodDo<T>(Action<T>, Action<Exception>, Action)Overloaded. Invokes the action for its side effects on each value in the observable sequence. (Defined by Observable.)
Public Extension MethodFinally<T>Invokes finallyAction after the source observable sequence terminates normally or by an exception. (Defined by Observable.)
Public Extension MethodFirst<T>Returns the first value of an observable sequence. (Defined by Observable.)
Public Extension MethodFirstOrDefault<T>Returns the first value of an observable sequence, or a default value if no value is found. (Defined by Observable.)
Public Extension MethodForkJoin<T, TRight, TResult>Runs all observable sequences in parallel and combines their last values. (Defined by Observable.)
Public Extension MethodGetEnumerator<T>Returns an enumerator that enumerates all values of the observable sequence. (Defined by Observable.)
Public Extension MethodGroupBy<T, TKey>(Func<T, TKey>)Overloaded. Groups the elements of an observable sequence according to a specified key selector function. (Defined by Observable.)
Public Extension MethodGroupBy<T, TKey>(Func<T, TKey>, IEqualityComparer<TKey>)Overloaded. Groups the elements of an observable sequence according to a specified key selector function and comparer. (Defined by Observable.)
Public Extension MethodGroupBy<T, TKey, TElement>(Func<T, TKey>, Func<T, TElement>)Overloaded. Groups the elements of an observable sequence and selects the resulting elements by using a specified function. (Defined by Observable.)
Public Extension MethodGroupBy<T, TKey, TElement>(Func<T, TKey>, Func<T, 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.)
Public Extension MethodIsEmpty<T>Determines whether an observable collection is empty. (Defined by Observable.)
Public Extension MethodLast<T>Returns the last value of an observable sequence. (Defined by Observable.)
Public Extension MethodLastOrDefault<T>Returns the last value of an observable sequence, or a default value if no value is found. (Defined by Observable.)
Public Extension MethodLatest<T>Samples the most recent value (buffer of size one with consumption) in an observable sequence. (Defined by Observable.)
Public Extension MethodLet<T, TResult>Binds the source to the parameter without sharing subscription side effects. (Defined by Observable.)
Public Extension MethodLongCount<T>Returns an Int64 value that represents the total number of values in an observable sequence. (Defined by Observable.)
Public Extension MethodMaterialize<T>Materializes the implicit notifications of an observable sequence as explicit notification values. (Defined by Observable.)
Public Extension MethodMax<T>()Overloaded. Returns the maximum value in an observable sequence. (Defined by Observable.)
Public Extension MethodMax<T>(IComparer<T>)Overloaded. Returns the maximum value in an observable sequence as determined by the specified comparer function. (Defined by Observable.)
Public Extension MethodMaxBy<T, TKey>(Func<T, TKey>)Overloaded. Returns the element in an observable sequence with the maximum key value. (Defined by Observable.)
Public Extension MethodMaxBy<T, TKey>(Func<T, TKey>, IComparer<TKey>)Overloaded. Returns the element in an observable sequence with the maximum key value. (Defined by Observable.)
Public Extension MethodMerge<T>(IObservable<T>)Overloaded. Merges an observable sequence of observable sequences into an observable sequence. (Defined by Observable.)
Public Extension MethodMerge<T>(IObservable<T>, IScheduler)Overloaded. Merges an observable sequence of observable sequences into an observable sequence. (Defined by Observable.)
Public Extension MethodMin<T>()Overloaded. Returns the minimum value in an observable sequence. (Defined by Observable.)
Public Extension MethodMin<T>(IComparer<T>)Overloaded. Returns the minimum value in an observable sequence as determined by the specified comparer function. (Defined by Observable.)
Public Extension MethodMinBy<T, TKey>(Func<T, TKey>)Overloaded. Returns the element in an observable sequence with the minimum key value. (Defined by Observable.)
Public Extension MethodMinBy<T, TKey>(Func<T, TKey>, IComparer<TKey>)Overloaded. Returns the element in an observable sequence with the minimum key value. (Defined by Observable.)
Public Extension MethodMostRecent<T>Samples the most recent value (buffer of size one without consumption) in an observable sequence. (Defined by Observable.)
Public Extension MethodNext<T>Samples the next value (blocking without buffering) from an observable sequence. (Defined by Observable.)
Public Extension MethodObserveOn<T>(Dispatcher)Overloaded. Asynchronously notify observers using the dispatcher. (Defined by DispatcherObservableExtensions.)
Public Extension MethodObserveOn<T>(SynchronizationContext)Overloaded. Asynchronously notifies observers on the synchronization context. (Defined by Observable.)
Public Extension MethodObserveOn<T>(DispatcherScheduler)Overloaded. Asynchronously notifies observers using the scheduler. (Defined by Observable.)
Public Extension MethodObserveOn<T>(IScheduler)Overloaded. Asynchronously notifies observers using the scheduler. (Defined by Observable.)
Public Extension MethodObserveOnDispatcher<T>Asynchronously notifies observers using the current dispatcher. (Defined by Observable.)
Public Extension MethodOnErrorResumeNext<T>Continues an observable sequence that is terminated normally or by an exception with the next observable sequence. (Defined by Observable.)
Public Extension MethodPrune<T>()Overloaded. Returns a connectable observable sequence that shares a single subscription to the underlying source containing only the last notification. (Defined by Observable.)
Public Extension MethodPrune<T>(IScheduler)Overloaded. Returns a connectable observable sequence that shares a single subscription to the underlying source containing only the last notification. (Defined by Observable.)
Public Extension MethodPrune<T, TResult>(Func<IObservable<T>, 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.)
Public Extension MethodPrune<T, TResult>(Func<IObservable<T>, 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.)
Public Extension MethodPublish<T>()Overloaded. Returns a connectable observable sequence that shares a single subscription to the underlying source. (Defined by Observable.)
Public Extension MethodPublish<T>(T)Overloaded. Returns a connectable observable sequence that shares a single subscription to the underlying source and starts with initialValue. (Defined by Observable.)
Public Extension MethodPublish<T>(T, IScheduler)Overloaded. Returns a connectable observable sequence that shares a single subscription to the underlying source and starts with initialValue. (Defined by Observable.)
Public Extension MethodPublish<T, TResult>(Func<IObservable<T>, 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.)
Public Extension MethodPublish<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, T)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.)
Public Extension MethodPublish<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, T, 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.)
Public Extension MethodRefCount<TSource>Returns an observable sequence that stays connected to the source as long as there is at least one subscription to the observable sequence. (Defined by Observable.)
Public Extension MethodRepeat<T>()Overloaded. Repeats the observable sequence indefinitely. (Defined by Observable.)
Public Extension MethodRepeat<T>(Int32)Overloaded. Repeats the observable sequence the specified number of times. (Defined by Observable.)
Public Extension MethodReplay<T>()Overloaded. Returns a connectable observable sequence that shares a single subscription to the underlying source replaying all notifications. (Defined by Observable.)
Public Extension MethodReplay<T>(TimeSpan)Overloaded. Returns a connectable observable sequence that shares a single subscription to the underlying source replaying all notifications within window. (Defined by Observable.)
Public Extension MethodReplay<T>(Int32)Overloaded. Returns a connectable observable sequence that shares a single subscription to the underlying source replaying bufferSize notifications. (Defined by Observable.)
Public Extension MethodReplay<T>(IScheduler)Overloaded. Returns a connectable observable sequence that shares a single subscription to the underlying source replaying all notifications. (Defined by Observable.)
Public Extension MethodReplay<T>(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.)
Public Extension MethodReplay<T>(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.)
Public Extension MethodReplay<T>(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.)
Public Extension MethodReplay<T>(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.)
Public Extension MethodReplay<T, TResult>(Func<IObservable<T>, 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.)
Public Extension MethodReplay<T, TResult>(Func<IObservable<T>, 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.)
Public Extension MethodReplay<T, TResult>(Func<IObservable<T>, 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.)
Public Extension MethodReplay<T, TResult>(Func<IObservable<T>, 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.)
Public Extension MethodReplay<T, TResult>(Func<IObservable<T>, 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.)
Public Extension MethodReplay<T, TResult>(Func<IObservable<T>, 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.)
Public Extension MethodReplay<T, TResult>(Func<IObservable<T>, 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.)
Public Extension MethodReplay<T, TResult>(Func<IObservable<T>, 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.)
Public Extension MethodRetry<T>()Overloaded. Repeats the source observable sequence until it successfully terminates. (Defined by Observable.)
Public Extension MethodRetry<T>(Int32)Overloaded. Repeats the source observable sequence for retryCount times or until it successfully terminates. (Defined by Observable.)
Public Extension MethodRun<T>()Overloaded. Invokes the observable sequence for its side effects and blocks until the sequence is terminated. (Defined by Observable.)
Public Extension MethodRun<T>(Action<T>)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.)
Public Extension MethodRun<T>(IObserver<T>)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.)
Public Extension MethodRun<T>(Action<T>, 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.)
Public Extension MethodRun<T>(Action<T>, 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.)
Public Extension MethodRun<T>(Action<T>, 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.)
Public Extension MethodSample<T>(TimeSpan)Overloaded. Samples the observable sequence at each interval. (Defined by Observable.)
Public Extension MethodSample<T>(TimeSpan, IScheduler)Overloaded. Samples the observable sequence at each interval. (Defined by Observable.)
Public Extension MethodScan<T>(Func<T, T, T>)Overloaded. Applies an accumulator function over an observable sequence and returns each intermediate result. (Defined by Observable.)
Public Extension MethodScan<T, TAccumulate>(TAccumulate, Func<TAccumulate, T, 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.)
Public Extension MethodScan0<T, 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.)
Public Extension MethodSelect<T, TResult>(Func<T, TResult>)Overloaded. Projects each value of an observable sequence into a new form. (Defined by Observable.)
Public Extension MethodSelect<T, TResult>(Func<T, Int32, TResult>)Overloaded. Projects each value of an observable sequence into a new form by incorporating the element's index. (Defined by Observable.)
Public Extension MethodSelectMany<T, TResult>(Func<T, 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.)
Public Extension MethodSelectMany<T, 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.)
Public Extension MethodSelectMany<T, TResult>(Func<T, 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.)
Public Extension MethodSelectMany<T, TResult>(Func<T, 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.)
Public Extension MethodSelectMany<T, TCollection, TResult>(Func<T, IObservable<TCollection>>, Func<T, 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.)
Public Extension MethodSingle<T>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.)
Public Extension MethodSingleOrDefault<T>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.)
Public Extension MethodSkip<T>Bypasses a specified number of values in an observable sequence and then returns the remaining values. (Defined by Observable.)
Public Extension MethodSkipLast<T>Bypasses a specified number of values at the end of an observable sequence. (Defined by Observable.)
Public Extension MethodSkipUntil<T, TOther>Returns the values from the source observable sequence only after the other observable sequence produces a value. (Defined by Observable.)
Public Extension MethodSkipWhile<T>Bypasses values in an observable sequence as long as a specified condition is true and then returns the remaining values. (Defined by Observable.)
Public Extension MethodStartWith<T>(T[])Overloaded. Prepends a sequence values to an observable sequence. (Defined by Observable.)
Public Extension MethodStartWith<T>(IScheduler, T[])Overloaded. Prepends a sequence values to an observable sequence. (Defined by Observable.)
Public Extension MethodSubscribe<T>()Overloaded. Evaluates the observable sequence. (Defined by ObservableExtensions.)
Public Extension MethodSubscribe<T>(Action<T>)Overloaded. Subscribes a value handler to an observable sequence. (Defined by ObservableExtensions.)
Public Extension MethodSubscribe<T>(Action<T>, Action<Exception>)Overloaded. Subscribes a value handler and an exception handler to an observable sequence. (Defined by ObservableExtensions.)
Public Extension MethodSubscribe<T>(Action<T>, Action)Overloaded. Subscribes a value handler and a completion handler to an observable sequence. (Defined by ObservableExtensions.)
Public Extension MethodSubscribe<T>(Action<T>, Action<Exception>, Action)Overloaded. Subscribes a value handler, an exception handler, and a completion handler to an observable sequence. (Defined by ObservableExtensions.)
Public Extension MethodSubscribeOn<T>(Dispatcher)Overloaded. Asynchronously subscribes and unsubscribes observers using the dispatcher. (Defined by DispatcherObservableExtensions.)
Public Extension MethodSubscribeOn<T>(SynchronizationContext)Overloaded. Asynchronously subscribes and unsubscribes observers on the synchronization context. (Defined by Observable.)
Public Extension MethodSubscribeOn<T>(DispatcherScheduler)Overloaded. Asynchronously subscribes and unsubscribes observers using the scheduler. (Defined by Observable.)
Public Extension MethodSubscribeOn<T>(IScheduler)Overloaded. Asynchronously subscribes and unsubscribes observers using the scheduler. (Defined by Observable.)
Public Extension MethodSubscribeOnDispatcher<T>Asynchronously subscribes and unsubscribes observers using the current dispatcher. (Defined by Observable.)
Public Extension MethodSynchronize<T>()Overloaded. Synchronizes the observable sequence. (Defined by Observable.)
Public Extension MethodSynchronize<T>(Object)Overloaded. Synchronizes the observable sequence. (Defined by Observable.)
Public Extension MethodTake<T>(Int32)Overloaded. Returns a specified number of contiguous values from the start of an observable sequence. (Defined by Observable.)
Public Extension MethodTake<T>(Int32, IScheduler)Overloaded. Returns a specified number of contiguous values from the start of an observable sequence. (Defined by Observable.)
Public Extension MethodTakeLast<T>Returns a specified number of contiguous values from the end of an observable sequence. (Defined by Observable.)
Public Extension MethodTakeUntil<T, TOther>Returns the values from the source observable sequence until the other observable sequence produces a value. (Defined by Observable.)
Public Extension MethodTakeWhile<T>Returns values from an observable sequence as long as a specified condition is true, and then skips the remaining values. (Defined by Observable.)
Public Extension MethodThen<T, TResult>Matches when the observable sequence has an available value and projects the value. (Defined by Observable.)
Public Extension MethodThrottle<T>(TimeSpan)Overloaded. Ignores values from an observable sequence that are followed by another value before the specified time span. (Defined by Observable.)
Public Extension MethodThrottle<T>(TimeSpan, IScheduler)Overloaded. Ignores values from an observable sequence that are followed by another value before the specified time span. (Defined by Observable.)
Public Extension MethodTimeInterval<T>()Overloaded. Records the time interval for each value of an observable sequence. (Defined by Observable.)
Public Extension MethodTimeInterval<T>(IScheduler)Overloaded. Records the time interval for each value of an observable sequence. (Defined by Observable.)
Public Extension MethodTimeout<T>(TimeSpan)Overloaded. Returns either the observable sequence or a TimeoutException if dueTime elapses. (Defined by Observable.)
Public Extension MethodTimeout<T>(DateTimeOffset)Overloaded. Returns either the observable sequence or a TimeoutException if dueTime elapses. (Defined by Observable.)
Public Extension MethodTimeout<T>(TimeSpan, IObservable<T>)Overloaded. Returns the source observable sequence or the other observable sequence if dueTime elapses. (Defined by Observable.)
Public Extension MethodTimeout<T>(DateTimeOffset, IObservable<T>)Overloaded. Returns the source observable sequence or the other observable sequence if dueTime elapses. (Defined by Observable.)
Public Extension MethodTimeout<T>(TimeSpan, IScheduler)Overloaded. Returns either the observable sequence or a TimeoutException if dueTime elapses. (Defined by Observable.)
Public Extension MethodTimeout<T>(DateTimeOffset, IScheduler)Overloaded. Returns either the observable sequence or a TimeoutException if dueTime elapses. (Defined by Observable.)
Public Extension MethodTimeout<T>(TimeSpan, IObservable<T>, IScheduler)Overloaded. Returns the source observable sequence or the other observable sequence if dueTime elapses. (Defined by Observable.)
Public Extension MethodTimeout<T>(DateTimeOffset, IObservable<T>, IScheduler)Overloaded. Returns the source observable sequence or the other observable sequence if dueTime elapses. (Defined by Observable.)
Public Extension MethodTimestamp<T>()Overloaded. Records the timestamp for each value of an observable sequence. (Defined by Observable.)
Public Extension MethodTimestamp<T>(IScheduler)Overloaded. Records the timestamp for each value of an observable sequence. (Defined by Observable.)
Public Extension MethodToEnumerable<T>Converts an observable sequence to an enumerable sequence. (Defined by Observable.)
Public Extension MethodWhere<T>(Func<T, Boolean>)Overloaded. Filters the values of an observable sequence based on a predicate. (Defined by Observable.)
Public Extension MethodWhere<T>(Func<T, Int32, Boolean>)Overloaded. Filters the values of an observable sequence based on a predicate by incorporating the element's index. (Defined by Observable.)
Public Extension MethodZip<T, TRight, TResult>(IEnumerable<TRight>, Func<T, TRight, TResult>)Overloaded. Merges an observable sequence and an enumerable sequence into one observable sequence by using the selector function. (Defined by Observable.)
Public Extension MethodZip<T, TRight, TResult>(IObservable<TRight>, Func<T, TRight, TResult>)Overloaded. Merges two observable sequences into one observable sequence by using the selector function. (Defined by Observable.)
Top

Windows Phone OS

Supported in: 7.1, 7.0

Windows Phone

Show: