Clear Up
SharpKit Reference

Observable Class

Provides a set of static methods for query operations over observable sequences.

Namespace: SharpKit.Rx

Base Types

System.Object

Methods

Name Description
aggregate<TSource>(IObservable<T>, JsFunc<T1, T2, TResult>)
aggregate<TSource, TAccumulate>(IObservable<T>, TAccumulate, JsFunc<T1, T2, TResult>)
all<TSource>(IObservable<T>, JsFunc<T, TResult>)
amb<TSource>(IObservable`1[])
amb<TSource>(IObservable<T>, IObservable<T>)
and<TLeft, TRight>(IObservable<T>, IObservable<T>)
any<TSource>(IObservable<T>, JsFunc<T, TResult>)
asObservable<TSource>(IObservable<T>)
average(IObservable<T>) Computes the average of an observable sequence of numeric values.
average(IObservable<T>) Computes the average of an observable sequence of numeric values.
average(IObservable<T>) Computes the average of an observable sequence of numeric values.
average(IObservable<T>) Computes the average of an observable sequence of numeric values.
average(IObservable<T>) Computes the average of an observable sequence of numeric values.
average(IObservable<T>) Computes the average of an observable sequence of numeric values.
buffer<TSource>(IObservable<T>, int, int)
buffer<TSource, TBufferClosing>(IObservable<T>, JsFunc<TResult>)
buffer<TSource, TBufferOpening, TBufferClosing>(IObservable<T>, IObservable<T>, JsFunc<T, TResult>)
bufferWithTime<TSource>(IObservable<T>, Int64, Int64, IScheduler)
bufferWithTime<TSource>(IObservable<T>, Int64, IScheduler)
bufferWithTimeOrCount<TSource>(IObservable<T>, Int64, int, IScheduler)
catchException<TSource>(IObservable<T>, IObservable<T>)
catchException<TSource>(IObservable`1[])
catchException<TSource, TException>(IObservable<T>, JsFunc<T, TResult>)
combineLatest<TFirst, TSecond, TResult>(IObservable<T>, IObservable<T>, JsFunc<T1, T2, TResult>)
combineLatest<TFirst, TSecond, TThird, TResult>(IObservable<T>, IObservable<T>, IObservable<T>, JsFunc<T1, T2, T3, TResult>)
combineLatest<TFirst, TSecond, TThird, TFourth, TResult>(IObservable<T>, IObservable<T>, IObservable<T>, IObservable<T>, JsFunc<T1, T2, T3, T4, TResult>)
combineLatest<TFirst, TSecond, TThird, TFourth, TFifth, TResult>(IObservable<T>, IObservable<T>, IObservable<T>, IObservable<T>, IObservable<T>, JsFunc<T1, T2, T3, T4, T5, TResult>)
concat<TSource>(IObservable`1[])
concat<TSource>(IObservable<T>, IObservable`1[])
concatObservable<TSource>(IObservable<T>)
contains<TSource>(IObservable<T>, TSource, JsFunc<T1, T2, TResult>)
count<TSource>(IObservable<T>)
create<TSource>(JsFunc<T, TResult>)
createWithDisposable<TSource>(JsFunc<T, TResult>)
defaultIfEmpty<TSource>(IObservable<T>, TSource)
defer<TValue>(JsFunc<TResult>)
delay<TSource>(IObservable<T>, JsDate, IScheduler)
delay<TSource>(IObservable<T>, Int64, IScheduler)
delaySubscription<TSource>(IObservable<T>, JsDate, IScheduler)
delaySubscription<TSource>(IObservable<T>, Int64, IScheduler)
delayWithSelector<TSource, TDelay>(IObservable<T>, IObservable<T>, JsFunc<T, TResult>)
delayWithSelector<TSource, TDelay>(IObservable<T>, JsFunc<T, TResult>)
Dematerialize<TSource>(IObservable<T>)
distinct<TSource>(IObservable<T>, JsFunc<T, TResult>)
distinct<TSource>(IObservable<T>)
distinct<TSource, TKey>(IObservable<T>, JsFunc<T, TResult>, JsFunc<T, TResult>)
distinctUntilChanged<TSource>(IObservable<T>, JsFunc<T1, T2, TResult>)
distinctUntilChanged<TSource, TKey>(IObservable<T>, JsFunc<T, TResult>, JsFunc<T1, T2, TResult>)
doAction<TSource>(IObservable<T>, IObserver<T>)
doAction<TSource>(IObservable<T>, JsAction<T>, JsAction<T>, JsAction)
doAction<TSource>(IObservable<T>, JsAction<T>, JsAction)
doWhile<TSource>(IObservable<T>, JsFunc<TResult>)
elementAt<TSource>(IObservable<T>, int)
elementAtOrDefault<TSource>(IObservable<T>, int, TSource)
empty<TResult>(IScheduler) Returns an empty observable sequence with the specified scheduler.
expand<TSource>(IObservable<T>, JsFunc<T, TResult>, IScheduler)
finallyAction<TSource>(IObservable<T>, JsAction)
forIn<TSource, TResult>(TSource[], JsFunc<T, TResult>)
forkJoin<TSource>(IObservable`1[])
forkJoin<TFirst, TSecond, TResult>(IObservable<T>, IObservable<T>, JsFunc<T1, T2, TResult>)
fromArray(JsArray, IScheduler) Converts an array to an observable sequence.
fromArray<T>(JsArray<T>, IScheduler)
generate<TState, TResult>(TState, JsFunc<T, TResult>, JsFunc<T, TResult>, JsFunc<T, TResult>, IScheduler)
generateWithAbsoluteTime<TState, TResult>(TState, JsFunc<T, TResult>, JsFunc<T, TResult>, JsFunc<T, TResult>, JsFunc<T, TResult>, IScheduler)
generateWithRelativeTime<TState, TResult>(TState, JsFunc<T, TResult>, JsFunc<T, TResult>, JsFunc<T, TResult>, JsFunc<T, TResult>, IScheduler)
groupBy<TSource, TKey>(IObservable<T>, JsFunc<T, TResult>, JsFunc<T, TResult>)
groupBy<TSource, TKey>(IObservable<T>, JsFunc<T, TResult>)
GroupBy<TSource, TKey>(IObservable<T>, JsFunc<T, TResult>)
groupBy<TSource, TKey, TElement>(IObservable<T>, JsFunc<T, TResult>, JsFunc<T, TResult>, JsFunc<T, TResult>)
GroupBy<TSource, TKey, TElement>(IObservable<T>, JsFunc<T, TResult>, JsFunc<T, TResult>)
groupByUntil<TSource, TKey, TDuration>(IObservable<T>, JsFunc<T, TResult>, JsFunc<T, TResult>, JsFunc<T, TResult>)
groupByUntil<TSource, TKey, TElement, TDuration>(IObservable<T>, JsFunc<T, TResult>, JsFunc<T, TResult>, JsFunc<T, TResult>, JsFunc<T, TResult>)
groupJoin<TLeft, TRight, TLeftDuration, TRightDuration, TResult>(IObservable<T>, IObservable<T>, JsFunc<T, TResult>, JsFunc<T, TResult>, JsFunc<T1, T2, TResult>)
ifThen<TResult>(JsFunc<TResult>, IObservable<T>, IObservable<T>)
ifThen<TResult>(JsFunc<TResult>, IObservable<T>, IScheduler)
ignoreElements<TSource>(IObservable<T>)
interval(Int64, IScheduler) Returns an observable sequence that produces a value after each period.
isEmpty<TSource>(IObservable<T>)
join<TLeft, TRight, TLeftDuration, TRightDuration, TResult>(IObservable<T>, IObservable<T>, JsFunc<T, TResult>, JsFunc<T, TResult>, JsFunc<T1, T2, TResult>)
letBind<TSource, TResult>(IObservable<T>, JsFunc<T, TResult>)
materialize<TSource>(IObservable<T>)
max<TSource>(IObservable<T>, JsFunc<T1, T2, TResult>)
maxBy<TSource, TKey>(IObservable<T>, JsFunc<T, TResult>, JsFunc<T1, T2, TResult>)
merge<TSource>(IObservable<T>, int)
merge<TSource>(IObservable<T>, IObservable<T>)
merge<TSource>(IObservable`1[])
merge<TSource>(IScheduler, IObservable`1[])
mergeObservable<TSource>(IObservable<T>)
min<TSource>(IObservable<T>, JsFunc<T1, T2, TResult>)
minBy<TSource, TKey>(IObservable<T>, JsFunc<T, TResult>, JsFunc<T1, T2, TResult>)
multicast<TSource, TResult>(IObservable<T>, ISubject<TSource, TResult>)
multicast<TSource, TIntermediate, TResult>(IObservable<T>, JsFunc<TResult>, JsFunc<T, TResult>)
never<TResult>() Returns a non-terminating observable sequence.
observerOn<TSource>(IObservable<T>, IScheduler)
onErrorResumeNext<TSource>(IObservable<T>, IObservable<T>)
onErrorResumeNext<TSource>(IObservable`1[])
publish<TSource>(IObservable<T>)
publish<TSource, TResult>(IObservable<T>, JsFunc<T, TResult>)
publishLast<TSource>(IObservable<T>)
publishLast<TSource, TResult>(IObservable<T>, JsFunc<T, TResult>)
publishValue<TSource>(IObservable<T>, TSource)
publishValue<TSource, TResult>(IObservable<T>, JsFunc<T, TResult>, TSource)
qequenceEqual<TSource>(IObservable<T>, IObservable<T>, JsFunc<T1, T2, TResult>)
range(int, int, IScheduler) Generates an observable sequence of integral numbers within a specified range.
refCount<TSource>(IConnectableObservable<T>)
repeat<TSource>(IObservable<T>, int)
repeat<TResult>(TResult, int, IScheduler)
repeat<TResult>(TResult, IScheduler)
replay<TSource>(IObservable<T>)
replay<TSource>(IObservable<T>, int, Int64, IScheduler)
replay<TSource>(IObservable<T>, Int64, IScheduler)
replay<TSource>(IObservable<T>, IScheduler)
replay<TSource, TResult>(IObservable<T>, JsFunc<T, TResult>, int, Int64, IScheduler)
replay<TSource, TResult>(IObservable<T>, JsFunc<T, TResult>, int, IScheduler)
replay<TSource, TResult>(IObservable<T>, JsFunc<T, TResult>, Int64, IScheduler)
replay<TSource, TResult>(IObservable<T>, JsFunc<T, TResult>, IScheduler)
retry<TSource>(IObservable<T>, int)
returnValue<TResult>(TResult, IScheduler)
sample<TSource>(IObservable<T>, Int64, IScheduler)
sample<TSource, TSample>(IObservable<T>, IObservable<T>)
scan<TSource>(IObservable<T>, JsFunc<T1, T2, TResult>)
scan<TSource, TAccumulate>(IObservable<T>, TAccumulate, JsFunc<T1, T2, TResult>)
select<TSource, TResult>(IObservable<T>, JsFunc<T, TResult>)
select<TSource, TResult>(IObservable<T>, JsFunc<T1, T2, TResult>)
Select<TSource, TResult>(IObservable<T>, JsFunc<T, TResult>)
selectMany<TSource, TResult>(IObservable<T>, JsFunc<T, TResult>)
selectMany<TSource, TOther>(IObservable<T>, IObservable<T>)
selectMany<TSource, TCollection, TResult>(IObservable<T>, JsFunc<T, TResult>, JsFunc<T1, T2, TResult>)
SelectMany<TSource, TCollection, TResult>(IObservable<T>, JsFunc<T, TResult>, JsFunc<T1, T2, TResult>)
skip<TSource>(IObservable<T>, int)
skipLast<TSource>(IObservable<T>, int)
skipUntil<TSource, TOther>(IObservable<T>, IObservable<T>)
skipWhile<TSource>(IObservable<T>, JsFunc<T1, T2, TResult>)
skipWhile<TSource>(IObservable<T>, JsFunc<T, TResult>)
start(JsAction, IScheduler) Invokes a function on the given instance and with the given arguments on the specified scheduler, producing the result through an observable sequence.
start(JsAction, object, IScheduler) Invokes a function on the given instance and with the given arguments on the specified scheduler, producing the result through an observable sequence.
start(JsAction, object, JsArray, IScheduler) Invokes a function on the given instance and with the given arguments on the specified scheduler, producing the result through an observable sequence.
start<TResult>(JsFunc<TResult>, IScheduler)
start<TResult>(JsFunc<TResult>, object, IScheduler)
start<TResult>(JsFunc<TResult>, object, JsArray, IScheduler)
startWith<TSource>(IObservable<T>, TSource[])
subscribe<T>(IObservable<T>, JsAction<T>, JsAction<T>, JsAction)
subscribe<T>(IObservable<T>, JsAction<T>, JsAction)
subscribeOn<TSource>(IObservable<T>, IScheduler)
sum(IObservable<T>) Computes the sum of a sequence of numeric values.
sum(IObservable<T>) Computes the sum of a sequence of numeric values.
sum(IObservable<T>) Computes the sum of a sequence of numeric values.
sum(IObservable<T>) Computes the sum of a sequence of numeric values.
sum(IObservable<T>) Computes the sum of a sequence of numeric values.
sum(IObservable<T>) Computes the sum of a sequence of numeric values.
switchCase<TValue, TResult>(JsFunc<TResult>, JsObject<K, T>, IObservable<T>)
switchCase<TValue, TResult>(JsFunc<TResult>, JsObject<K, T>, IScheduler)
switchLatest<TSource>(IObservable<T>)
take<TSource>(IObservable<T>, int, IScheduler)
takeLast<TSource>(IObservable<T>, int)
takeUntil<TSource, TOther>(IObservable<T>, IObservable<T>)
takeWhile<TSource>(IObservable<T>, JsFunc<T1, T2, TResult>)
takeWhile<TSource>(IObservable<T>, JsFunc<T, TResult>)
then<TSource, TResult>(IObservable<T>, JsFunc<T, TResult>)
throttle<TSource>(IObservable<T>, Int64, IScheduler)
throttleWithSelector<TSource, TThrottle>(IObservable<T>, JsFunc<T, TResult>)
throwException<TResult>(JsError, IScheduler) Returns an observable sequence that terminates with an exception.
timeInterval<TSource>(IObservable<T>, IScheduler)
timeout<TSource>(IObservable<T>, Int64, IObservable<T>, IScheduler)
timeout<TSource>(IObservable<T>, JsDate, IObservable<T>, IScheduler)
timeout<TSource>(IObservable<T>, Int64, IScheduler)
timeout<TSource>(IObservable<T>, JsDate, IScheduler)
timeoutWithSelector<TSource, TTimeout>(IObservable<T>, JsFunc<T, TResult>, IObservable<T>)
timeoutWithSelector<TSource, TTimeout>(IObservable<T>, IObservable<T>, JsFunc<T, TResult>, IObservable<T>)
timer(JsDate, Int64, IScheduler) Returns an observable sequence that produces a value after dueTime has elapsed and then after each period.
timer(JsDate, IScheduler) Returns an observable sequence that produces a value after dueTime has elapsed and then after each period.
timer(Int64, Int64, IScheduler) Returns an observable sequence that produces a value after dueTime has elapsed and then after each period.
timer(Int64, IScheduler) Returns an observable sequence that produces a value after dueTime has elapsed and then after each period.
timestamp<TSource>(IObservable<T>, IScheduler)
toArray<TSource>(IObservable<T>)
toAsync(JsAction, IScheduler) Converts a function to an asynchronous function that returns an observable sequence with the function's result.
toAsync<T1>(JsAction<T>, IScheduler)
toAsync<TResult>(JsFunc<TResult>, IScheduler)
toAsync<T1, T2>(JsAction<T1, T2>, IScheduler)
toAsync<T1, TResult>(JsFunc<T, TResult>, IScheduler)
toAsync<T1, T2, T3>(JsAction<T1, T2, T3>, IScheduler)
toAsync<T1, T2, TResult>(JsFunc<T1, T2, TResult>, IScheduler)
toAsync<T1, T2, T3, T4>(JsAction<T1, T2, T3, T4>, IScheduler)
toAsync<T1, T2, T3, TResult>(JsFunc<T1, T2, T3, TResult>, IScheduler)
toAsync<T1, T2, T3, T4, TResult>(JsFunc<T1, T2, T3, T4, TResult>, IScheduler)
toObservable(JsArray, IScheduler) Converts an array to an observable sequence.
toObservable<T>(JsArray<T>, IScheduler)
toObservable<T>(T[], IScheduler)
using<TSource, TResource>(JsFunc<TResult>, JsFunc<T, TResult>)
when<TResult>(Plan`1[])
where<TSource>(IObservable<T>, JsFunc<T, TResult>)
where<TSource>(IObservable<T>, JsFunc<T1, T2, TResult>)
Where<TSource>(IObservable<T>, JsFunc<T, TResult>)
whileDo<TSource>(JsFunc<TResult>, IObservable<T>)
window<TSource, TBufferClosing>(IObservable<T>, JsFunc<TResult>)
window<TSource, TBufferOpening, TBufferClosing>(IObservable<T>, IObservable<T>, JsFunc<T, TResult>)
windowWithCount<TSource>(IObservable<T>, int, int)
windowWithTime<TSource>(IObservable<T>, Int64, Int64, IScheduler)
windowWithTime<TSource>(IObservable<T>, Int64, IScheduler)
windowWithTimeOrCount<TSource>(IObservable<T>, Int64, int, IScheduler)
zip<TFirst, TSecond, TResult>(IObservable<T>, IObservable<T>, JsFunc<T1, T2, TResult>)
zip<TFirst, TSecond, TThird, TResult>(IObservable<T>, IObservable<T>, IObservable<T>, JsFunc<T1, T2, T3, TResult>)
zip<TFirst, TSecond, TThird, TFourth, TResult>(IObservable<T>, IObservable<T>, IObservable<T>, IObservable<T>, JsFunc<T1, T2, T3, T4, TResult>)
zip<TFirst, TSecond, TThird, TFourth, TFifth, TResult>(IObservable<T>, IObservable<T>, IObservable<T>, IObservable<T>, IObservable<T>, JsFunc<T1, T2, T3, T4, T5, TResult>)
© Copyright 2005-2011 SharpKit. All rights reserved.