Clear Up
SharpKit Reference

Observable Class

Represents a push-style collection.

Namespace: SharpKit.Rx

Base Types

System.Object

Base Interfaces

Constructors

Name Description
Observable()

Methods

Name Description
Aggregate(object, Func<object, object, object>)
Aggregate1(Func<object, object, object>)
All(Func<object, bool>)
Amb(Observable) Returns the observable sequence that reacts first.
Amb(Observable, Observable) Returns the observable sequence that reacts first.
Amb(Observable, Observable, Observable) Returns the observable sequence that reacts first.
Amb(Observable, Observable, Observable, Observable) Returns the observable sequence that reacts first.
And(Observable) Matches when both observable sequences have an available value.
Any() Determines whether an observable sequence contains any elements.
Any(Func<object, bool>)
AsObservable() Hides the identity of an observable sequence.
Average() Computes the average of a sequence of numeric values.
BufferWithCount(int) Projects each value of an observable sequence into a buffer.
BufferWithCount(int, int) Projects each value of an observable sequence into a buffer.
BufferWithTime(int) Projects each value of an observable sequence into a buffer.
BufferWithTime(int, int) Projects each value of an observable sequence into a buffer.
BufferWithTime(int, int, Scheduler) Projects each value of an observable sequence into a buffer.
BufferWithTimeOrCount(int, int) Projects each value of an observable sequence into a buffer.
BufferWithTimeOrCount(int, int, Scheduler) Projects each value of an observable sequence into a buffer.
Case(Func<Observable>, JsObject)
Case(Func<Observable>, JsObject, Observable)
Case(Func<Observable>, JsObject, Observable, Scheduler)
Catch(Observable[]) Continues an observable sequence that is terminated by an exception with the next observable sequence.
Catch(Observable[], Scheduler) Continues an observable sequence that is terminated by an exception with the next observable sequence.
Catch(Observable) Continues an observable sequence that is terminated by an exception with the next observable sequence.
Catch(Observable, Observable) Continues an observable sequence that is terminated by an exception with the next observable sequence.
Catch(Observable, Observable, Observable) Continues an observable sequence that is terminated by an exception with the next observable sequence.
Catch(Observable, Observable, Observable, Observable) Continues an observable sequence that is terminated by an exception with the next observable sequence.
CombineLatest(Observable, Func<object, object, object>)
Concat(Observable[]) Concatenates all the observable sequences.
Concat(Observable[], Scheduler) Concatenates all the observable sequences.
Concat(Observable) Concatenates all the observable sequences.
Concat(Observable, Observable) Concatenates all the observable sequences.
Concat(Observable, Observable, Observable) Concatenates all the observable sequences.
Concat(Observable, Observable, Observable, Observable) Concatenates all the observable sequences.
Contains(object) Determines whether an observable sequence contains a specified element by using the default comparer.
Contains(object, Func<object, bool, bool>)
Count() Returns an number representing the total number of elements in an observable sequence.
Create(Func<Observer, Action>)
CreateWithDisposable(Func<Observer, IDisposable>)
Defer(Func<Observable>)
Delay(int) Time shifts the observable sequence by dueTime. The relative time intervals between the values are preserved.
Delay(int, Scheduler) Time shifts the observable sequence by dueTime. The relative time intervals between the values are preserved.
Dematerialize() Dematerializes the explicit notification values of an observable sequence as implicit notifications.
DistinctUntilChanged() Returns an observable sequence that contains only distinct contiguous values.
DistinctUntilChanged(Func<object, object>)
DistinctUntilChanged(Func<object, object>, Func<object, bool, bool>)
Do(Action<object>)
Do(Action<object>, Action<object>)
Do(Action<object>, Action<object>, Action)
Do(Observer) Invokes the observer for its side-effects on each value in the observable sequence.
DoWhile(Observable, Func<bool>)
Empty() Returns an empty observable sequence.
Empty(Scheduler) Returns an empty observable sequence.
Final() Returns an observable that contains only the final OnNext value.
Finally(Action) Invokes finallyAction after source observable sequence terminates normally or by an exception.
For(Array, Func<object, Observable>)
ForkJoin(Observable, Observable) Runs all observable sequences in parallel and combines their last values.
ForkJoin(Observable, Observable, Observable) Runs all observable sequences in parallel and combines their last values.
ForkJoin(Observable, Observable, Observable, Observable) Runs all observable sequences in parallel and combines their last values.
ForkJoin(Observable, Observable, Observable, Observable, Observable) Runs all observable sequences in parallel and combines their last values.
FromArray(Object[]) Returns an observable sequence that contains all values from the array in order.
FromArray(Object[], Scheduler) Returns an observable sequence that contains all values from the array in order.
FromDOMEvent(HtmlElement, string) Returns an observable sequence that contains the values of the underlying DOM event.
FromDOMEvent(HtmlDocument, string) Returns an observable sequence that contains the values of the underlying DOM event.
FromDOMEvent(HtmlWindow, string) Returns an observable sequence that contains the values of the underlying DOM event.
FromHtmlEvent(HtmlElement, string) Returns an observable sequence that contains the values of the underlying Html event.
FromHtmlEvent(HtmlDocument, string) Returns an observable sequence that contains the values of the underlying Html event.
FromHtmlEvent(HtmlWindow, string) Returns an observable sequence that contains the values of the underlying Html event.
FromIEEvent(HtmlElement, string) Returns an observable sequence that contains the values of the underlying Internet Explorer event.
FromIEEvent(HtmlDocument, string) Returns an observable sequence that contains the values of the underlying Internet Explorer event.
FromIEEvent(HtmlWindow, string) Returns an observable sequence that contains the values of the underlying Internet Explorer event.
Generate(Func<object>, Func<object, bool>, Func<object, object>, Func<object, object>)
Generate(Func<object>, Func<object, bool>, Func<object, object>, Func<object, object>, Scheduler)
GenerateWithTime(Func<object>, Func<object, bool>, Func<object, object>, Func<object, object>, Func<object, int>)
GenerateWithTime(Func<object>, Func<object, bool>, Func<object, object>, Func<object, object>, Func<object, int>, Scheduler)
GroupBy(Func<object, object>)
GroupBy(Func<object, object>, Func<object, object>)
GroupBy(Func<object, object>, Func<object, object>, Func<object, string>)
If(Func<bool>, Observable, Observable)
Interval(int) Returns an observable sequence that produces a value after each period.
Interval(int, Scheduler) Returns an observable sequence that produces a value after each period.
IsEmpty() Determines whether an observable sequence is empty.
Join(Plan, Plan) Joins together the results from several plans.
Join(Plan, Plan, Plan) Joins together the results from several plans.
Join(Plan, Plan, Plan, Plan) Joins together the results from several plans.
Join(Plan, Plan, Plan, Plan, Plan) Joins together the results from several plans.
Join(Plan, Plan, Plan, Plan, Plan, Plan) Joins together the results from several plans.
Join(Plan, Plan, Plan, Plan, Plan, Plan, Plan) Joins together the results from several plans.
Join(Plan, Plan, Plan, Plan, Plan, Plan, Plan, Plan) Joins together the results from several plans.
Join(Plan) Joins together the results from several plans.
Let(object, Func<object, Observable>)
Let(Func<Observable, Observable>)
Let(Func<Observable, Observable>, Func<ISubject>)
Materialize() Materializes the implicit notifications of an observable sequence as explicit notification values.
Max() Returns the maximum value in an observable sequence.
MaxBy(Func<object, object>)
MaxBy(Func<object, object>, Func<object, object, int>)
Merge(Observable[]) Merges all the observable sequences into a single observable sequence.
Merge(Observable[], Scheduler) Merges all the observable sequences into a single observable sequence.
Merge(Observable) Merges all the observable sequences into a single observable sequence.
Merge(Observable, Observable) Merges all the observable sequences into a single observable sequence.
Merge(Observable, Observable, Observable) Merges all the observable sequences into a single observable sequence.
Merge(Observable, Observable, Observable, Observable) Merges all the observable sequences into a single observable sequence.
MergeObservable() Merges an observable sequence of observable sequences into an observable sequence.
Min() Returns the minimum value in an observable sequence.
MinBy(Func<object, object>)
MinBy(Func<object, object>, Func<object, object, int>)
Never() Returns a non-terminating observable sequence.
OnErrorResumeNext(Observable[]) Continues an observable sequence that is terminated normally or by an exception with the next observable sequence.
OnErrorResumeNext(Observable[], Scheduler) Continues an observable sequence that is terminated normally or by an exception with the next observable sequence.
OnErrorResumeNext(Observable) Continues an observable sequence that is terminated normally or by an exception with the next observable sequence.
OnErrorResumeNext(Observable, Observable) Continues an observable sequence that is terminated normally or by an exception with the next observable sequence.
OnErrorResumeNext(Observable, Observable, Observable) Continues an observable sequence that is terminated normally or by an exception with the next observable sequence.
OnErrorResumeNext(Observable, Observable, Observable, Observable) Continues an observable sequence that is terminated normally or by an exception with the next observable sequence.
Prune() Returns a connectable observable sequence that shares a single subscription to the underlying source containing only the last notification.
Prune(Func<Observable, Observable>)
Prune(Func<Observable, Observable>, Scheduler)
Publish() Returns a connectable observable sequence that shares a single subscription to the underlying source.
Publish(Func<Observable, Observable>)
Range(int, int) Generates an observable sequence of integral numbers within a specified range.
Range(int, int, Scheduler) Generates an observable sequence of integral numbers within a specified range.
RemoveInterval() Removes the timestamp from each value of an observable sequence.
RemoveTimestamp() Removes the timestamp from each value of an observable sequence.
Repeat(object) Generates an observable sequence that contains one repeated value.
Repeat(object, int) Generates an observable sequence that contains one repeated value.
Repeat(object, int, Scheduler) Generates an observable sequence that contains one repeated value.
Repeat() Repeats the observable sequence indefinitely.
Repeat(int) Repeats the observable sequence repeatCount times.
Repeat(int, Scheduler) Repeats the observable sequence repeatCount times.
Replay() Returns a connectable observable sequence that shares a single subscription to the underlying source replaying all notifications.
Replay(Func<Observable, Observable>)
Replay(Func<Observable, Observable>, int)
Replay(Func<Observable, Observable>, int, int)
Replay(Func<Observable, Observable>, int, int, Scheduler)
Retry() Repeats the source observable sequence until it successfully terminates.
Retry(int) Repeats the source observable sequence the retryCount times or until it successfully terminates.
Retry(int, Scheduler) Repeats the source observable sequence the retryCount times or until it successfully terminates.
Return(object) Returns an observable sequence that contains a single value.
Return(object, Scheduler) Returns an observable sequence that contains a single value.
Sample(int) Samples the observable sequence at each interval.
Sample(int, Scheduler) Samples the observable sequence at each interval.
Scan(object, Func<object, object, object>)
Scan0(object, Func<object, object, object>)
Scan1(Func<object, object, object>)
Select(Func<object, object>)
Select(Func<object, int, object>)
SelectMany(Func<object, Observable>)
Skip(int) Bypasses a specified number of values in an observable sequence and then returns the remaining values.
SkipLast(int) Bypasses a specified number of values at the end of an observable sequence.
SkipUntil(Observable) Returns the values from the source observable sequence only after the other observable sequence produces a value.
SkipWhile(Func<object, bool>)
Start(Action, object, Object[]) Invokes the action asynchronously.
Start(Func<object>, object, Object[])
Start(Action<object>, object, Object[])
Start(Func<object, object>, object, Object[])
Start(Func<object, Object[], object>, object, Object[])
Start(Action, Scheduler) Invokes the action asynchronously, using scheduler to schedule the work.
Start(Func<object>, Scheduler)
Start(Action<object>, Scheduler)
Start(Func<object, object>, Scheduler)
Start(Func<object, Object[], object>, Scheduler)
Start(Action, object, Scheduler) Invokes the action asynchronously, using scheduler to schedule the work.
Start(Func<object>, object, Scheduler)
Start(Action<object>, object, Scheduler)
Start(Func<object, object>, object, Scheduler)
Start(Func<object, Object[], object>, object, Scheduler)
Start(Action, object, Object[], Scheduler) Invokes the action asynchronously, using scheduler to schedule the work.
Start(Func<object>, object, Object[], Scheduler)
Start(Action<object>, object, Object[], Scheduler)
Start(Func<object, object>, object, Object[], Scheduler)
Start(Func<object, Object[], object>, object, Object[], Scheduler)
Start(Action) Invokes the action asynchronously.
Start(Func<object>)
Start(Action<object>)
Start(Func<object, object>)
Start(Func<object, Object[], object>)
Start(Action, object) Invokes the action asynchronously.
Start(Func<object>, object)
Start(Action<object>, object)
Start(Func<object, object>, object)
Start(Func<object, Object[], object>, object)
StartWith(object, Scheduler) Prepends a value to an observable sequence.
StartWith(Object[]) Prepends a sequence values to an observable sequence.
StartWith(Object[], Scheduler) Prepends a sequence values to an observable sequence.
StartWith(object) Prepends a value to an observable sequence.
Subscribe() Subscribes to the observable sequence for its side-effects.
Subscribe(IObserver) Subscribes an observer to the observable sequence.
Subscribe(Action<object>)
Subscribe(Action<object>, Action<object>)
Subscribe(Action<object>, Action<object>, Action)
Sum() Computes the sum of a sequence of numeric values.
Switch() Transforms an observable sequence of observable sequences into an observable sequence producing values only from the most recent observable sequence.
Take(int) Returns a specified number of contiguous values from the start of an observable sequence.
Take(int, Scheduler) Returns a specified number of contiguous values from the start of an observable sequence.
TakeLast(int) Returns a specified number of contiguous values from the end of an observable sequence.
TakeUntil(Observable) Returns the values from the source observable sequence until the other observable sequence produces a value.
TakeWhile(Func<object, bool>)
Then(JsFunction) Matches when the observable sequence has an available value and projects the value.
Throttle(int) Ignores values from an observable sequence which are followed by another value before dueTime.
Throttle(int, Scheduler) Ignores values from an observable sequence which are followed by another value before dueTime.
Throw(object) Returns an observable sequence that terminates with an exception.
Throw(object, Scheduler) Returns an observable sequence that terminates with an exception.
TimeInterval() Records the time interval for each value of an observable sequence.
TimeInterval(Scheduler) Records the time interval for each value of an observable sequence according to the scheduler's notion of time.
Timeout(int) Returns observable sequence that ends with a TimeoutException if dueTime elapses.
Timeout(int, Scheduler) Returns observable sequence that ends with a TimeoutException if dueTime elapses.
Timeout(int, Observable) Returns the source observable sequence until completed or if dueTime elapses replaces the observable sequence with other.
Timeout(int, Observable, Scheduler) Returns the source observable sequence until completed or if dueTime elapses replaces the observable sequence with other.
Timer(int) Returns an observable sequence that produces a value at dueTime.
Timer(int, int) Returns an observable sequence that produces a value after dueTime has elapsed and then after each period.
Timer(int, int, Scheduler) Returns an observable sequence that produces a value after dueTime has elapsed and then after each period.
Timestamp() Records the timestamp for each value of an observable sequence.
Timestamp(Scheduler) Records the timestamp for each value of an observable sequence according to the scheduler's notion of time.
ToAsync(Action) Converts the action into an asynchronous function.
ToAsync(Func<object>)
ToAsync(Action<object>)
ToAsync(Func<object, object>)
ToAsync(Func<object, Object[], object>)
ToAsync(Action, Scheduler) Converts the action into an asynchronous function, using scheduler to schedule the work.
ToAsync(Func<object>, Scheduler)
ToAsync(Action<object>, Scheduler)
ToAsync(Func<object, object>, Scheduler)
ToAsync(Func<object, Object[], object>, Scheduler)
Using(Func<IDisposable>, Func<IDisposable, Observable>)
Where(Func<object, bool>)
Where(Func<object, int, bool>)
While(Func<bool>, Observable)
XmlHttpRequest(XmlHttpRequestDetails) Starts an asynchronous XmlHttpRequest.
XmlHttpRequest(string) Starts an asynchronous XmlHttpRequest.
Zip(Observable, Func<object, object, object>)
© Copyright 2005-2011 SharpKit. All rights reserved.