Export (0) Print
Expand All

ISubject<T> Interface

March 22, 2012

Represents an object that is both an observable sequence as well as an observer.

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

public interface ISubject<T> : ISubject<T, T>, 
	IObserver<T>, IObservable<T>

Type Parameters

T

The ISubject<T> type exposes the following members.

  NameDescription
Public methodOnCompletedNotifies the observer of the end of the observable sequence. No further values or notifications will be made available for this sequence. (Inherited from IObserver<T>.)
Public methodOnErrorNotifies the observer that an exception has occurred in processing the observable sequence. (Inherited from IObserver<T>.)
Public methodOnNextNotifies the observer of a new value in the observable sequence. (Inherited from IObserver<T>.)
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 MethodAsObserver<T>Hides the identity of an observer. (Defined by Observer.)
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 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 MethodToNotifier<T>Creates a notification callback from an observer. (Defined by Observer.)
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:
© 2014 Microsoft