Home Library Learn Samples Downloads Support Community Forums
This topic has not yet been rated - Rate this topic

Observable Methods

March 22, 2012

The Observable type exposes the following members.

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

Did you find this helpful?
(1500 characters remaining)
© 2013 Microsoft. All rights reserved.
|
Site Feedback
© 2013 Microsoft. All rights reserved.