Defined in rx-lite.d.ts:500
Defined in rx-lite.d.ts:507
public catch( handler: (exception: any) => Rx.Observable<T> ) : Observable Parameters
handler: (exception: any) => Rx.Observable<T>
Returns
Observable
public catch( handler: (exception: any) => Rx.IPromise<T> ) : Observable Parameters
handler: (exception: any) => Rx.IPromise<T>
Returns
Observable
Parameters
Returns
Observable
public catchException( handler: (exception: any) => Rx.Observable<T> ) : Observable Parameters
handler: (exception: any) => Rx.Observable<T>
Returns
Observable
public catchException( handler: (exception: any) => Rx.IPromise<T> ) : Observable Parameters
handler: (exception: any) => Rx.IPromise<T>
Returns
Observable
Parameters
Returns
Observable
public combineLatest( second: Observable , resultSelector: (v1: T, v2: T2) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2) => TResult
Returns
Observable
public combineLatest( second: IPromise , resultSelector: (v1: T, v2: T2) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2) => TResult
Returns
Observable
public combineLatest( second: Observable , third: Observable , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public combineLatest( second: Observable , third: IPromise , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: Observable , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: IPromise , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public combineLatest( second: Observable , third: Observable , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: Observable , third: Observable , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: Observable , third: IPromise , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: Observable , third: IPromise , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: Observable , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: Observable , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: IPromise , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: IPromise , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: Observable , third: Observable , fourth: Observable , fifth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult
Returns
Observable
public combineLatest( souces: Observable [] , resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult ) : Observable Parameters
resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult
Returns
Observable
public combineLatest( souces: IPromise [] , resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult ) : Observable Parameters
resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult
Returns
Observable
public concatAll( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
public concatMap( selector: (value: T, index: number) => Rx.Observable<T2> , resultSelector: (value1: T, value2: T2, index: number) => R ) : Observable Parameters
selector: (value: T, index: number) => Rx.Observable<T2>
resultSelector: (value1: T, value2: T2, index: number) => R
Returns
Observable
public concatMap( selector: (value: T, index: number) => Rx.IPromise<T2> , resultSelector: (value1: T, value2: T2, index: number) => R ) : Observable Parameters
selector: (value: T, index: number) => Rx.IPromise<T2>
resultSelector: (value1: T, value2: T2, index: number) => R
Returns
Observable
public concatMap( selector: (value: T, index: number) => Rx.Observable<R> ) : Observable Parameters
selector: (value: T, index: number) => Rx.Observable<R>
Returns
Observable
public concatMap( selector: (value: T, index: number) => Rx.IPromise<R> ) : Observable Parameters
selector: (value: T, index: number) => Rx.IPromise<R>
Returns
Observable
Parameters
Returns
Observable
public concatObservable( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
public controlled( enableQueue?: boolean ) : ControlledObservable Attaches a controller to the observable sequence with the ability to queue.
Parameters
enableQueue?: boolean optional
Returns
ControlledObservable
public delayWithSelector( delayDurationSelector: (item: T) => number ) : Observable Parameters
delayDurationSelector: (item: T) => number
Returns
Observable
public delayWithSelector( subscriptionDelay: number , delayDurationSelector: (item: T) => number ) : Observable Parameters
subscriptionDelay: number
delayDurationSelector: (item: T) => number
Returns
Observable
public distinctUntilChanged( skipParameter: boolean , comparer: (x: T, y: T) => boolean ) : Observable Parameters
skipParameter: boolean
comparer: (x: T, y: T) => boolean
Returns
Observable
public distinctUntilChanged( keySelector?: (value: T) => TValue , comparer?: (x: TValue, y: TValue) => boolean ) : Observable Parameters
keySelector?: (value: T) => TValue optional
comparer?: (x: TValue, y: TValue) => boolean optional
Returns
Observable
Parameters
Returns
Observable
public do( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : Observable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
Observable
Parameters
Returns
Observable
public doAction( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : Observable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
Observable
public filter( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg?: any ) : Observable Parameters
predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean
thisArg?: any optional
Returns
Observable
public flatMap( selector: (value: T) => Rx.Observable<TOther> , resultSelector: (item: T, other: TOther) => TResult ) : Observable Parameters
selector: (value: T) => Rx.Observable<TOther>
resultSelector: (item: T, other: TOther) => TResult
Returns
Observable
public flatMap( selector: (value: T) => Rx.IPromise<TOther> , resultSelector: (item: T, other: TOther) => TResult ) : Observable Parameters
selector: (value: T) => Rx.IPromise<TOther>
resultSelector: (item: T, other: TOther) => TResult
Returns
Observable
public flatMap( selector: (value: T) => Rx.Observable<TResult> ) : Observable Parameters
selector: (value: T) => Rx.Observable<TResult>
Returns
Observable
public flatMap( selector: (value: T) => Rx.IPromise<TResult> ) : Observable Parameters
selector: (value: T) => Rx.IPromise<TResult>
Returns
Observable
Parameters
Returns
Observable
Parameters
Returns
Observable
public flatMapLatest( selector: (value: T, index: number, source: Rx.Observable<T>) => TResult , thisArg?: any ) : Observable Projects each element of an observable sequence into a new sequence of observable sequences by incorporating the element's index and then
transforms an observable sequence of observable sequences into an observable sequence producing values only from the most recent observable sequence.
Parameters
Returns
Observable
An observable sequence whose elements are the result of invoking the transform function on each element of source producing an Observable of Observable sequences
and that at any point in time produces the elements of the most recent inner observable sequence that has been received.
public forEach( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
public hasObservers( ) : boolean Returns
boolean
public map( selector: (value: T, index: number, source: Rx.Observable<T>) => TResult , thisArg?: any ) : Observable Parameters
selector: (value: T, index: number, source: Rx.Observable<T>) => TResult
thisArg?: any optional
Returns
Observable
public merge( maxConcurrent: number ) : T in Rx.Observable<T> Parameters
Returns
T in Rx.Observable<T>
Parameters
Returns
Observable
Parameters
Returns
Observable
public mergeAll( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
public mergeObservable( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
Parameters
Returns
ConnectableObservable
public multicast( subjectSelector: () => Rx.ISubject<T> , selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<T> ) : Observable Parameters
subjectSelector: () => Rx.ISubject<T>
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<T>
Returns
Observable
public onError( exception: any ) Parameters
public onNext( value: T in Rx.IObserver<T> ) Parameters
value: T in Rx.IObserver<T>
Returns a new observable that triggers on the second and subsequent triggerings of the input observable.
The Nth triggering of the input observable passes the arguments from the N-1th and Nth triggering as a pair.
The argument passed to the N-1th triggering is held in hidden internal state until the Nth triggering occurs.
Returns
Observable
An observable that triggers on successive pairs of observations from the input observable as an array.
public partition( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg: any ) : Observable [] Returns two observables which partition the observations of the source by the given function.
The first will trigger observations for those values for which the predicate returns true.
The second will trigger observations for those values where the predicate returns false.
The predicate is executed once for each subscribed observer.
Both also propagate all error observations arising from the source and each completes
when the source completes.
Parameters
Returns
Observable []
An array of observables. The first triggers when the predicate returns true,
and the second triggers when the predicate returns false.
Pauses the underlying observable sequence based upon the observable sequence which yields true/false.
Parameters
Returns
Observable
The observable sequence which is paused based upon the pauser.
Parameters
Returns
PausableObservable
Pauses the underlying observable sequence based upon the observable sequence which yields true/false,
and yields the values that were buffered while paused.
Parameters
Returns
PausableObservable
The observable sequence which is paused based upon the pauser.
Returns
ConnectableObservable
public publish( selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult> ) : Observable Parameters
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult>
Returns
Observable
Returns
ConnectableObservable
public publishLast( selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult> ) : Observable Parameters
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult>
Returns
Observable
public publishValue( initialValue: T in Rx.Observable<T> ) : ConnectableObservable Parameters
initialValue: T in Rx.Observable<T>
Returns
ConnectableObservable
public publishValue( selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult> , initialValue: T in Rx.Observable<T> ) : Observable Parameters
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult>
initialValue: T in Rx.Observable<T>
Returns
Observable
public repeat( repeatCount?: number ) : Observable Parameters
repeatCount?: number optional
Returns
Observable
public replay( selector?: boolean , bufferSize?: number , window?: number , scheduler?: IScheduler ) : ConnectableObservable Parameters
selector?: boolean optional
bufferSize?: number optional
window?: number optional
scheduler?: IScheduler optional
Returns
ConnectableObservable
public replay( selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<T> , bufferSize?: number , window?: number , scheduler?: IScheduler ) : Observable Parameters
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<T>
bufferSize?: number optional
window?: number optional
scheduler?: IScheduler optional
Returns
Observable
public retry( retryCount?: number ) : Observable Parameters
retryCount?: number optional
Returns
Observable
public scan( seed: TAcc , accumulator: (acc: TAcc, value: T) => TAcc ) : Observable Parameters
seed: TAcc
accumulator: (acc: TAcc, value: T) => TAcc
Returns
Observable
public scan( accumulator: (acc: T, value: T) => T ) : Observable Parameters
accumulator: (acc: T, value: T) => T
Returns
Observable
public select( selector: (value: T, index: number, source: Rx.Observable<T>) => TResult , thisArg?: any ) : Observable Parameters
selector: (value: T, index: number, source: Rx.Observable<T>) => TResult
thisArg?: any optional
Returns
Observable
public selectConcat( selector: (value: T, index: number) => Rx.Observable<T2> , resultSelector: (value1: T, value2: T2, index: number) => R ) : Observable Parameters
selector: (value: T, index: number) => Rx.Observable<T2>
resultSelector: (value1: T, value2: T2, index: number) => R
Returns
Observable
public selectConcat( selector: (value: T, index: number) => Rx.IPromise<T2> , resultSelector: (value1: T, value2: T2, index: number) => R ) : Observable Parameters
selector: (value: T, index: number) => Rx.IPromise<T2>
resultSelector: (value1: T, value2: T2, index: number) => R
Returns
Observable
public selectConcat( selector: (value: T, index: number) => Rx.Observable<R> ) : Observable Parameters
selector: (value: T, index: number) => Rx.Observable<R>
Returns
Observable
public selectConcat( selector: (value: T, index: number) => Rx.IPromise<R> ) : Observable Parameters
selector: (value: T, index: number) => Rx.IPromise<R>
Returns
Observable
Parameters
Returns
Observable
public selectMany( selector: (value: T) => Rx.Observable<TOther> , resultSelector: (item: T, other: TOther) => TResult ) : Observable Parameters
selector: (value: T) => Rx.Observable<TOther>
resultSelector: (item: T, other: TOther) => TResult
Returns
Observable
public selectMany( selector: (value: T) => Rx.IPromise<TOther> , resultSelector: (item: T, other: TOther) => TResult ) : Observable Parameters
selector: (value: T) => Rx.IPromise<TOther>
resultSelector: (item: T, other: TOther) => TResult
Returns
Observable
public selectMany( selector: (value: T) => Rx.Observable<TResult> ) : Observable Parameters
selector: (value: T) => Rx.Observable<TResult>
Returns
Observable
public selectMany( selector: (value: T) => Rx.IPromise<TResult> ) : Observable Parameters
selector: (value: T) => Rx.IPromise<TResult>
Returns
Observable
Parameters
Returns
Observable
Parameters
Returns
Observable
public selectSwitch( selector: (value: T, index: number, source: Rx.Observable<T>) => TResult , thisArg?: any ) : Observable Projects each element of an observable sequence into a new sequence of observable sequences by incorporating the element's index and then
transforms an observable sequence of observable sequences into an observable sequence producing values only from the most recent observable sequence.
Parameters
Returns
Observable
An observable sequence whose elements are the result of invoking the transform function on each element of source producing an Observable of Observable sequences
and that at any point in time produces the elements of the most recent inner observable sequence that has been received.
Returns an observable sequence that shares a single subscription to the underlying sequence.
This operator is a specialization of publish which creates a subscription when the number of observers goes from zero to one, then shares that subscription with all subsequent observers until the number of observers returns to zero, at which point the subscription is disposed.
Returns
Observable
An observable sequence that contains the elements of a sequence produced by multicasting the source sequence.
public shareReplay( bufferSize?: number , window?: number , scheduler?: IScheduler ) : Observable Parameters
bufferSize?: number optional
window?: number optional
scheduler?: IScheduler optional
Returns
Observable
public shareValue( initialValue: T in Rx.Observable<T> ) : Observable Returns an observable sequence that shares a single subscription to the underlying sequence and starts with an initialValue.
This operator is a specialization of publishValue which creates a subscription when the number of observers goes from zero to one, then shares that subscription with all subsequent observers until the number of observers returns to zero, at which point the subscription is disposed.
Parameters
Returns
Observable
An observable sequence that contains the elements of a sequence produced by multicasting the source sequence.
public skipWhile( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg?: any ) : Observable Parameters
predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean
thisArg?: any optional
Returns
Observable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
public switch( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
public switchLatest( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
public takeWhile( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg?: any ) : Observable Parameters
predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean
thisArg?: any optional
Returns
Observable
public throttleWithSelector( throttleDurationSelector: (item: T) => Rx.Observable<TTimeout> ) : Observable Parameters
throttleDurationSelector: (item: T) => Rx.Observable<TTimeout>
Returns
Observable
public timeoutWithSelector( firstTimeout: Observable , timeoutdurationSelector?: (item: T) => Rx.Observable<TTimeout> , other?: Observable ) : Observable Parameters
timeoutdurationSelector?: (item: T) => Rx.Observable<TTimeout> optional
Returns
Observable
public toNotifier( ) : (notification: Rx.Notification<T>) => void Returns
(notification: Rx.Notification<T>) => void
public toPromise( promiseCtor: new(resolver: (resolvePromise: (value: T) => void, rejectPromise: (reason: any) => void) => void) => TPromise ) : TPromise Converts an existing observable sequence to an ES6 Compatible Promise
Parameters
Returns
TPromise
An ES6 compatible promise with the last value from the observable sequence.
public toPromise( promiseCtor?: new(resolver: (resolvePromise: (value: T) => void, rejectPromise: (reason: any) => void) => void) => Rx.IPromise<T> ) : IPromise Converts an existing observable sequence to an ES6 Compatible Promise
Parameters
promiseCtor?: new(resolver: (resolvePromise: (value: T) => void, rejectPromise: (reason: any) => void) => void) => Rx.IPromise<T> optional
Returns
IPromise
An ES6 compatible promise with the last value from the observable sequence.
public where( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg?: any ) : Observable Parameters
predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean
thisArg?: any optional
Returns
Observable
public zip( second: Observable , resultSelector: (v1: T, v2: T2) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2) => TResult
Returns
Observable
public zip( second: IPromise , resultSelector: (v1: T, v2: T2) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2) => TResult
Returns
Observable
public zip( second: Observable , third: Observable , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public zip( second: Observable , third: IPromise , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public zip( second: IPromise , third: Observable , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public zip( second: IPromise , third: IPromise , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public zip( second: Observable , third: Observable , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: Observable , third: Observable , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: Observable , third: IPromise , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: Observable , third: IPromise , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: IPromise , third: Observable , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: IPromise , third: Observable , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: IPromise , third: IPromise , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: IPromise , third: IPromise , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: Observable , third: Observable , fourth: Observable , fifth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult
Returns
Observable
public zip( second: Observable [] , resultSelector: (left: T, ...right: TOther[]) => TResult ) : Observable Parameters
resultSelector: (left: T, ...right: TOther[]) => TResult
Returns
Observable
public zip( second: IPromise [] , resultSelector: (left: T, ...right: TOther[]) => TResult ) : Observable Parameters
resultSelector: (left: T, ...right: TOther[]) => TResult
Returns
Observable
Defined in rx.binding-lite.d.ts:8
Defined in rx.binding-lite.d.ts:15
public catch( handler: (exception: any) => Rx.Observable<T> ) : Observable Parameters
handler: (exception: any) => Rx.Observable<T>
Returns
Observable
public catch( handler: (exception: any) => Rx.IPromise<T> ) : Observable Parameters
handler: (exception: any) => Rx.IPromise<T>
Returns
Observable
Parameters
Returns
Observable
public catchException( handler: (exception: any) => Rx.Observable<T> ) : Observable Parameters
handler: (exception: any) => Rx.Observable<T>
Returns
Observable
public catchException( handler: (exception: any) => Rx.IPromise<T> ) : Observable Parameters
handler: (exception: any) => Rx.IPromise<T>
Returns
Observable
Parameters
Returns
Observable
public combineLatest( second: Observable , resultSelector: (v1: T, v2: T2) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2) => TResult
Returns
Observable
public combineLatest( second: IPromise , resultSelector: (v1: T, v2: T2) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2) => TResult
Returns
Observable
public combineLatest( second: Observable , third: Observable , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public combineLatest( second: Observable , third: IPromise , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: Observable , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: IPromise , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public combineLatest( second: Observable , third: Observable , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: Observable , third: Observable , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: Observable , third: IPromise , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: Observable , third: IPromise , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: Observable , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: Observable , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: IPromise , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: IPromise , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: Observable , third: Observable , fourth: Observable , fifth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult
Returns
Observable
public combineLatest( souces: Observable [] , resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult ) : Observable Parameters
resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult
Returns
Observable
public combineLatest( souces: IPromise [] , resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult ) : Observable Parameters
resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult
Returns
Observable
public concatAll( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
public concatMap( selector: (value: T, index: number) => Rx.Observable<T2> , resultSelector: (value1: T, value2: T2, index: number) => R ) : Observable Parameters
selector: (value: T, index: number) => Rx.Observable<T2>
resultSelector: (value1: T, value2: T2, index: number) => R
Returns
Observable
public concatMap( selector: (value: T, index: number) => Rx.IPromise<T2> , resultSelector: (value1: T, value2: T2, index: number) => R ) : Observable Parameters
selector: (value: T, index: number) => Rx.IPromise<T2>
resultSelector: (value1: T, value2: T2, index: number) => R
Returns
Observable
public concatMap( selector: (value: T, index: number) => Rx.Observable<R> ) : Observable Parameters
selector: (value: T, index: number) => Rx.Observable<R>
Returns
Observable
public concatMap( selector: (value: T, index: number) => Rx.IPromise<R> ) : Observable Parameters
selector: (value: T, index: number) => Rx.IPromise<R>
Returns
Observable
Parameters
Returns
Observable
public concatObservable( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
public controlled( enableQueue?: boolean ) : ControlledObservable Attaches a controller to the observable sequence with the ability to queue.
Parameters
enableQueue?: boolean optional
Returns
ControlledObservable
public delayWithSelector( delayDurationSelector: (item: T) => number ) : Observable Parameters
delayDurationSelector: (item: T) => number
Returns
Observable
public delayWithSelector( subscriptionDelay: number , delayDurationSelector: (item: T) => number ) : Observable Parameters
subscriptionDelay: number
delayDurationSelector: (item: T) => number
Returns
Observable
public distinctUntilChanged( skipParameter: boolean , comparer: (x: T, y: T) => boolean ) : Observable Parameters
skipParameter: boolean
comparer: (x: T, y: T) => boolean
Returns
Observable
public distinctUntilChanged( keySelector?: (value: T) => TValue , comparer?: (x: TValue, y: TValue) => boolean ) : Observable Parameters
keySelector?: (value: T) => TValue optional
comparer?: (x: TValue, y: TValue) => boolean optional
Returns
Observable
Parameters
Returns
Observable
public do( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : Observable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
Observable
Parameters
Returns
Observable
public doAction( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : Observable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
Observable
public filter( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg?: any ) : Observable Parameters
predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean
thisArg?: any optional
Returns
Observable
public flatMap( selector: (value: T) => Rx.Observable<TOther> , resultSelector: (item: T, other: TOther) => TResult ) : Observable Parameters
selector: (value: T) => Rx.Observable<TOther>
resultSelector: (item: T, other: TOther) => TResult
Returns
Observable
public flatMap( selector: (value: T) => Rx.IPromise<TOther> , resultSelector: (item: T, other: TOther) => TResult ) : Observable Parameters
selector: (value: T) => Rx.IPromise<TOther>
resultSelector: (item: T, other: TOther) => TResult
Returns
Observable
public flatMap( selector: (value: T) => Rx.Observable<TResult> ) : Observable Parameters
selector: (value: T) => Rx.Observable<TResult>
Returns
Observable
public flatMap( selector: (value: T) => Rx.IPromise<TResult> ) : Observable Parameters
selector: (value: T) => Rx.IPromise<TResult>
Returns
Observable
Parameters
Returns
Observable
Parameters
Returns
Observable
public flatMapLatest( selector: (value: T, index: number, source: Rx.Observable<T>) => TResult , thisArg?: any ) : Observable Projects each element of an observable sequence into a new sequence of observable sequences by incorporating the element's index and then
transforms an observable sequence of observable sequences into an observable sequence producing values only from the most recent observable sequence.
Parameters
Returns
Observable
An observable sequence whose elements are the result of invoking the transform function on each element of source producing an Observable of Observable sequences
and that at any point in time produces the elements of the most recent inner observable sequence that has been received.
public forEach( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
public hasObservers( ) : boolean Returns
boolean
public map( selector: (value: T, index: number, source: Rx.Observable<T>) => TResult , thisArg?: any ) : Observable Parameters
selector: (value: T, index: number, source: Rx.Observable<T>) => TResult
thisArg?: any optional
Returns
Observable
public merge( maxConcurrent: number ) : T in Rx.Observable<T> Parameters
Returns
T in Rx.Observable<T>
Parameters
Returns
Observable
Parameters
Returns
Observable
public mergeAll( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
public mergeObservable( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
Parameters
Returns
ConnectableObservable
public multicast( subjectSelector: () => Rx.ISubject<T> , selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<T> ) : Observable Parameters
subjectSelector: () => Rx.ISubject<T>
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<T>
Returns
Observable
public onError( exception: any ) Parameters
public onNext( value: T in Rx.IObserver<T> ) Parameters
value: T in Rx.IObserver<T>
Returns a new observable that triggers on the second and subsequent triggerings of the input observable.
The Nth triggering of the input observable passes the arguments from the N-1th and Nth triggering as a pair.
The argument passed to the N-1th triggering is held in hidden internal state until the Nth triggering occurs.
Returns
Observable
An observable that triggers on successive pairs of observations from the input observable as an array.
public partition( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg: any ) : Observable [] Returns two observables which partition the observations of the source by the given function.
The first will trigger observations for those values for which the predicate returns true.
The second will trigger observations for those values where the predicate returns false.
The predicate is executed once for each subscribed observer.
Both also propagate all error observations arising from the source and each completes
when the source completes.
Parameters
Returns
Observable []
An array of observables. The first triggers when the predicate returns true,
and the second triggers when the predicate returns false.
Pauses the underlying observable sequence based upon the observable sequence which yields true/false.
Parameters
Returns
Observable
The observable sequence which is paused based upon the pauser.
Parameters
Returns
PausableObservable
Pauses the underlying observable sequence based upon the observable sequence which yields true/false,
and yields the values that were buffered while paused.
Parameters
Returns
PausableObservable
The observable sequence which is paused based upon the pauser.
Returns
ConnectableObservable
public publish( selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult> ) : Observable Parameters
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult>
Returns
Observable
Returns
ConnectableObservable
public publishLast( selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult> ) : Observable Parameters
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult>
Returns
Observable
public publishValue( initialValue: T in Rx.Observable<T> ) : ConnectableObservable Parameters
initialValue: T in Rx.Observable<T>
Returns
ConnectableObservable
public publishValue( selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult> , initialValue: T in Rx.Observable<T> ) : Observable Parameters
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult>
initialValue: T in Rx.Observable<T>
Returns
Observable
public repeat( repeatCount?: number ) : Observable Parameters
repeatCount?: number optional
Returns
Observable
public replay( selector?: boolean , bufferSize?: number , window?: number , scheduler?: IScheduler ) : ConnectableObservable Parameters
selector?: boolean optional
bufferSize?: number optional
window?: number optional
scheduler?: IScheduler optional
Returns
ConnectableObservable
public replay( selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<T> , bufferSize?: number , window?: number , scheduler?: IScheduler ) : Observable Parameters
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<T>
bufferSize?: number optional
window?: number optional
scheduler?: IScheduler optional
Returns
Observable
public retry( retryCount?: number ) : Observable Parameters
retryCount?: number optional
Returns
Observable
public scan( seed: TAcc , accumulator: (acc: TAcc, value: T) => TAcc ) : Observable Parameters
seed: TAcc
accumulator: (acc: TAcc, value: T) => TAcc
Returns
Observable
public scan( accumulator: (acc: T, value: T) => T ) : Observable Parameters
accumulator: (acc: T, value: T) => T
Returns
Observable
public select( selector: (value: T, index: number, source: Rx.Observable<T>) => TResult , thisArg?: any ) : Observable Parameters
selector: (value: T, index: number, source: Rx.Observable<T>) => TResult
thisArg?: any optional
Returns
Observable
public selectConcat( selector: (value: T, index: number) => Rx.Observable<T2> , resultSelector: (value1: T, value2: T2, index: number) => R ) : Observable Parameters
selector: (value: T, index: number) => Rx.Observable<T2>
resultSelector: (value1: T, value2: T2, index: number) => R
Returns
Observable
public selectConcat( selector: (value: T, index: number) => Rx.IPromise<T2> , resultSelector: (value1: T, value2: T2, index: number) => R ) : Observable Parameters
selector: (value: T, index: number) => Rx.IPromise<T2>
resultSelector: (value1: T, value2: T2, index: number) => R
Returns
Observable
public selectConcat( selector: (value: T, index: number) => Rx.Observable<R> ) : Observable Parameters
selector: (value: T, index: number) => Rx.Observable<R>
Returns
Observable
public selectConcat( selector: (value: T, index: number) => Rx.IPromise<R> ) : Observable Parameters
selector: (value: T, index: number) => Rx.IPromise<R>
Returns
Observable
Parameters
Returns
Observable
public selectMany( selector: (value: T) => Rx.Observable<TOther> , resultSelector: (item: T, other: TOther) => TResult ) : Observable Parameters
selector: (value: T) => Rx.Observable<TOther>
resultSelector: (item: T, other: TOther) => TResult
Returns
Observable
public selectMany( selector: (value: T) => Rx.IPromise<TOther> , resultSelector: (item: T, other: TOther) => TResult ) : Observable Parameters
selector: (value: T) => Rx.IPromise<TOther>
resultSelector: (item: T, other: TOther) => TResult
Returns
Observable
public selectMany( selector: (value: T) => Rx.Observable<TResult> ) : Observable Parameters
selector: (value: T) => Rx.Observable<TResult>
Returns
Observable
public selectMany( selector: (value: T) => Rx.IPromise<TResult> ) : Observable Parameters
selector: (value: T) => Rx.IPromise<TResult>
Returns
Observable
Parameters
Returns
Observable
Parameters
Returns
Observable
public selectSwitch( selector: (value: T, index: number, source: Rx.Observable<T>) => TResult , thisArg?: any ) : Observable Projects each element of an observable sequence into a new sequence of observable sequences by incorporating the element's index and then
transforms an observable sequence of observable sequences into an observable sequence producing values only from the most recent observable sequence.
Parameters
Returns
Observable
An observable sequence whose elements are the result of invoking the transform function on each element of source producing an Observable of Observable sequences
and that at any point in time produces the elements of the most recent inner observable sequence that has been received.
Returns an observable sequence that shares a single subscription to the underlying sequence.
This operator is a specialization of publish which creates a subscription when the number of observers goes from zero to one, then shares that subscription with all subsequent observers until the number of observers returns to zero, at which point the subscription is disposed.
Returns
Observable
An observable sequence that contains the elements of a sequence produced by multicasting the source sequence.
public shareReplay( bufferSize?: number , window?: number , scheduler?: IScheduler ) : Observable Parameters
bufferSize?: number optional
window?: number optional
scheduler?: IScheduler optional
Returns
Observable
public shareValue( initialValue: T in Rx.Observable<T> ) : Observable Returns an observable sequence that shares a single subscription to the underlying sequence and starts with an initialValue.
This operator is a specialization of publishValue which creates a subscription when the number of observers goes from zero to one, then shares that subscription with all subsequent observers until the number of observers returns to zero, at which point the subscription is disposed.
Parameters
Returns
Observable
An observable sequence that contains the elements of a sequence produced by multicasting the source sequence.
public skipWhile( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg?: any ) : Observable Parameters
predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean
thisArg?: any optional
Returns
Observable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
public switch( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
public switchLatest( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
public takeWhile( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg?: any ) : Observable Parameters
predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean
thisArg?: any optional
Returns
Observable
public throttleWithSelector( throttleDurationSelector: (item: T) => Rx.Observable<TTimeout> ) : Observable Parameters
throttleDurationSelector: (item: T) => Rx.Observable<TTimeout>
Returns
Observable
public timeoutWithSelector( firstTimeout: Observable , timeoutdurationSelector?: (item: T) => Rx.Observable<TTimeout> , other?: Observable ) : Observable Parameters
timeoutdurationSelector?: (item: T) => Rx.Observable<TTimeout> optional
Returns
Observable
public toNotifier( ) : (notification: Rx.Notification<T>) => void Returns
(notification: Rx.Notification<T>) => void
public toPromise( promiseCtor: new(resolver: (resolvePromise: (value: T) => void, rejectPromise: (reason: any) => void) => void) => TPromise ) : TPromise Converts an existing observable sequence to an ES6 Compatible Promise
Parameters
Returns
TPromise
An ES6 compatible promise with the last value from the observable sequence.
public toPromise( promiseCtor?: new(resolver: (resolvePromise: (value: T) => void, rejectPromise: (reason: any) => void) => void) => Rx.IPromise<T> ) : IPromise Converts an existing observable sequence to an ES6 Compatible Promise
Parameters
promiseCtor?: new(resolver: (resolvePromise: (value: T) => void, rejectPromise: (reason: any) => void) => void) => Rx.IPromise<T> optional
Returns
IPromise
An ES6 compatible promise with the last value from the observable sequence.
public where( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg?: any ) : Observable Parameters
predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean
thisArg?: any optional
Returns
Observable
public zip( second: Observable , resultSelector: (v1: T, v2: T2) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2) => TResult
Returns
Observable
public zip( second: IPromise , resultSelector: (v1: T, v2: T2) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2) => TResult
Returns
Observable
public zip( second: Observable , third: Observable , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public zip( second: Observable , third: IPromise , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public zip( second: IPromise , third: Observable , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public zip( second: IPromise , third: IPromise , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public zip( second: Observable , third: Observable , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: Observable , third: Observable , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: Observable , third: IPromise , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: Observable , third: IPromise , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: IPromise , third: Observable , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: IPromise , third: Observable , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: IPromise , third: IPromise , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: IPromise , third: IPromise , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: Observable , third: Observable , fourth: Observable , fifth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult
Returns
Observable
public zip( second: Observable [] , resultSelector: (left: T, ...right: TOther[]) => TResult ) : Observable Parameters
resultSelector: (left: T, ...right: TOther[]) => TResult
Returns
Observable
public zip( second: IPromise [] , resultSelector: (left: T, ...right: TOther[]) => TResult ) : Observable Parameters
resultSelector: (left: T, ...right: TOther[]) => TResult
Returns
Observable
Defined in rx.binding-lite.d.ts:26
Defined in rx.binding-lite.d.ts:35
public catch( handler: (exception: any) => Rx.Observable<T> ) : Observable Parameters
handler: (exception: any) => Rx.Observable<T>
Returns
Observable
public catch( handler: (exception: any) => Rx.IPromise<T> ) : Observable Parameters
handler: (exception: any) => Rx.IPromise<T>
Returns
Observable
Parameters
Returns
Observable
public catchException( handler: (exception: any) => Rx.Observable<T> ) : Observable Parameters
handler: (exception: any) => Rx.Observable<T>
Returns
Observable
public catchException( handler: (exception: any) => Rx.IPromise<T> ) : Observable Parameters
handler: (exception: any) => Rx.IPromise<T>
Returns
Observable
Parameters
Returns
Observable
public combineLatest( second: Observable , resultSelector: (v1: T, v2: T2) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2) => TResult
Returns
Observable
public combineLatest( second: IPromise , resultSelector: (v1: T, v2: T2) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2) => TResult
Returns
Observable
public combineLatest( second: Observable , third: Observable , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public combineLatest( second: Observable , third: IPromise , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: Observable , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: IPromise , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public combineLatest( second: Observable , third: Observable , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: Observable , third: Observable , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: Observable , third: IPromise , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: Observable , third: IPromise , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: Observable , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: Observable , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: IPromise , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: IPromise , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: Observable , third: Observable , fourth: Observable , fifth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult
Returns
Observable
public combineLatest( souces: Observable [] , resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult ) : Observable Parameters
resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult
Returns
Observable
public combineLatest( souces: IPromise [] , resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult ) : Observable Parameters
resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult
Returns
Observable
public concatAll( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
public concatMap( selector: (value: T, index: number) => Rx.Observable<T2> , resultSelector: (value1: T, value2: T2, index: number) => R ) : Observable Parameters
selector: (value: T, index: number) => Rx.Observable<T2>
resultSelector: (value1: T, value2: T2, index: number) => R
Returns
Observable
public concatMap( selector: (value: T, index: number) => Rx.IPromise<T2> , resultSelector: (value1: T, value2: T2, index: number) => R ) : Observable Parameters
selector: (value: T, index: number) => Rx.IPromise<T2>
resultSelector: (value1: T, value2: T2, index: number) => R
Returns
Observable
public concatMap( selector: (value: T, index: number) => Rx.Observable<R> ) : Observable Parameters
selector: (value: T, index: number) => Rx.Observable<R>
Returns
Observable
public concatMap( selector: (value: T, index: number) => Rx.IPromise<R> ) : Observable Parameters
selector: (value: T, index: number) => Rx.IPromise<R>
Returns
Observable
Parameters
Returns
Observable
public concatObservable( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
public controlled( enableQueue?: boolean ) : ControlledObservable Attaches a controller to the observable sequence with the ability to queue.
Parameters
enableQueue?: boolean optional
Returns
ControlledObservable
public delayWithSelector( delayDurationSelector: (item: T) => number ) : Observable Parameters
delayDurationSelector: (item: T) => number
Returns
Observable
public delayWithSelector( subscriptionDelay: number , delayDurationSelector: (item: T) => number ) : Observable Parameters
subscriptionDelay: number
delayDurationSelector: (item: T) => number
Returns
Observable
public distinctUntilChanged( skipParameter: boolean , comparer: (x: T, y: T) => boolean ) : Observable Parameters
skipParameter: boolean
comparer: (x: T, y: T) => boolean
Returns
Observable
public distinctUntilChanged( keySelector?: (value: T) => TValue , comparer?: (x: TValue, y: TValue) => boolean ) : Observable Parameters
keySelector?: (value: T) => TValue optional
comparer?: (x: TValue, y: TValue) => boolean optional
Returns
Observable
Parameters
Returns
Observable
public do( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : Observable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
Observable
Parameters
Returns
Observable
public doAction( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : Observable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
Observable
public filter( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg?: any ) : Observable Parameters
predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean
thisArg?: any optional
Returns
Observable
public flatMap( selector: (value: T) => Rx.Observable<TOther> , resultSelector: (item: T, other: TOther) => TResult ) : Observable Parameters
selector: (value: T) => Rx.Observable<TOther>
resultSelector: (item: T, other: TOther) => TResult
Returns
Observable
public flatMap( selector: (value: T) => Rx.IPromise<TOther> , resultSelector: (item: T, other: TOther) => TResult ) : Observable Parameters
selector: (value: T) => Rx.IPromise<TOther>
resultSelector: (item: T, other: TOther) => TResult
Returns
Observable
public flatMap( selector: (value: T) => Rx.Observable<TResult> ) : Observable Parameters
selector: (value: T) => Rx.Observable<TResult>
Returns
Observable
public flatMap( selector: (value: T) => Rx.IPromise<TResult> ) : Observable Parameters
selector: (value: T) => Rx.IPromise<TResult>
Returns
Observable
Parameters
Returns
Observable
Parameters
Returns
Observable
public flatMapLatest( selector: (value: T, index: number, source: Rx.Observable<T>) => TResult , thisArg?: any ) : Observable Projects each element of an observable sequence into a new sequence of observable sequences by incorporating the element's index and then
transforms an observable sequence of observable sequences into an observable sequence producing values only from the most recent observable sequence.
Parameters
Returns
Observable
An observable sequence whose elements are the result of invoking the transform function on each element of source producing an Observable of Observable sequences
and that at any point in time produces the elements of the most recent inner observable sequence that has been received.
public forEach( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
public map( selector: (value: T, index: number, source: Rx.Observable<T>) => TResult , thisArg?: any ) : Observable Parameters
selector: (value: T, index: number, source: Rx.Observable<T>) => TResult
thisArg?: any optional
Returns
Observable
public merge( maxConcurrent: number ) : T in Rx.Observable<T> Parameters
Returns
T in Rx.Observable<T>
Parameters
Returns
Observable
Parameters
Returns
Observable
public mergeAll( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
public mergeObservable( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
Parameters
Returns
ConnectableObservable
public multicast( subjectSelector: () => Rx.ISubject<T> , selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<T> ) : Observable Parameters
subjectSelector: () => Rx.ISubject<T>
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<T>
Returns
Observable
Returns a new observable that triggers on the second and subsequent triggerings of the input observable.
The Nth triggering of the input observable passes the arguments from the N-1th and Nth triggering as a pair.
The argument passed to the N-1th triggering is held in hidden internal state until the Nth triggering occurs.
Returns
Observable
An observable that triggers on successive pairs of observations from the input observable as an array.
public partition( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg: any ) : Observable [] Returns two observables which partition the observations of the source by the given function.
The first will trigger observations for those values for which the predicate returns true.
The second will trigger observations for those values where the predicate returns false.
The predicate is executed once for each subscribed observer.
Both also propagate all error observations arising from the source and each completes
when the source completes.
Parameters
Returns
Observable []
An array of observables. The first triggers when the predicate returns true,
and the second triggers when the predicate returns false.
Pauses the underlying observable sequence based upon the observable sequence which yields true/false.
Parameters
Returns
Observable
The observable sequence which is paused based upon the pauser.
Parameters
Returns
PausableObservable
Pauses the underlying observable sequence based upon the observable sequence which yields true/false,
and yields the values that were buffered while paused.
Parameters
Returns
PausableObservable
The observable sequence which is paused based upon the pauser.
Returns
ConnectableObservable
public publish( selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult> ) : Observable Parameters
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult>
Returns
Observable
Returns
ConnectableObservable
public publishLast( selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult> ) : Observable Parameters
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult>
Returns
Observable
public publishValue( initialValue: T in Rx.Observable<T> ) : ConnectableObservable Parameters
initialValue: T in Rx.Observable<T>
Returns
ConnectableObservable
public publishValue( selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult> , initialValue: T in Rx.Observable<T> ) : Observable Parameters
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult>
initialValue: T in Rx.Observable<T>
Returns
Observable
Defined in rx.binding-lite.d.ts:28
Returns
Observable
public repeat( repeatCount?: number ) : Observable Parameters
repeatCount?: number optional
Returns
Observable
public replay( selector?: boolean , bufferSize?: number , window?: number , scheduler?: IScheduler ) : ConnectableObservable Parameters
selector?: boolean optional
bufferSize?: number optional
window?: number optional
scheduler?: IScheduler optional
Returns
ConnectableObservable
public replay( selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<T> , bufferSize?: number , window?: number , scheduler?: IScheduler ) : Observable Parameters
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<T>
bufferSize?: number optional
window?: number optional
scheduler?: IScheduler optional
Returns
Observable
public retry( retryCount?: number ) : Observable Parameters
retryCount?: number optional
Returns
Observable
public scan( seed: TAcc , accumulator: (acc: TAcc, value: T) => TAcc ) : Observable Parameters
seed: TAcc
accumulator: (acc: TAcc, value: T) => TAcc
Returns
Observable
public scan( accumulator: (acc: T, value: T) => T ) : Observable Parameters
accumulator: (acc: T, value: T) => T
Returns
Observable
public select( selector: (value: T, index: number, source: Rx.Observable<T>) => TResult , thisArg?: any ) : Observable Parameters
selector: (value: T, index: number, source: Rx.Observable<T>) => TResult
thisArg?: any optional
Returns
Observable
public selectConcat( selector: (value: T, index: number) => Rx.Observable<T2> , resultSelector: (value1: T, value2: T2, index: number) => R ) : Observable Parameters
selector: (value: T, index: number) => Rx.Observable<T2>
resultSelector: (value1: T, value2: T2, index: number) => R
Returns
Observable
public selectConcat( selector: (value: T, index: number) => Rx.IPromise<T2> , resultSelector: (value1: T, value2: T2, index: number) => R ) : Observable Parameters
selector: (value: T, index: number) => Rx.IPromise<T2>
resultSelector: (value1: T, value2: T2, index: number) => R
Returns
Observable
public selectConcat( selector: (value: T, index: number) => Rx.Observable<R> ) : Observable Parameters
selector: (value: T, index: number) => Rx.Observable<R>
Returns
Observable
public selectConcat( selector: (value: T, index: number) => Rx.IPromise<R> ) : Observable Parameters
selector: (value: T, index: number) => Rx.IPromise<R>
Returns
Observable
Parameters
Returns
Observable
public selectMany( selector: (value: T) => Rx.Observable<TOther> , resultSelector: (item: T, other: TOther) => TResult ) : Observable Parameters
selector: (value: T) => Rx.Observable<TOther>
resultSelector: (item: T, other: TOther) => TResult
Returns
Observable
public selectMany( selector: (value: T) => Rx.IPromise<TOther> , resultSelector: (item: T, other: TOther) => TResult ) : Observable Parameters
selector: (value: T) => Rx.IPromise<TOther>
resultSelector: (item: T, other: TOther) => TResult
Returns
Observable
public selectMany( selector: (value: T) => Rx.Observable<TResult> ) : Observable Parameters
selector: (value: T) => Rx.Observable<TResult>
Returns
Observable
public selectMany( selector: (value: T) => Rx.IPromise<TResult> ) : Observable Parameters
selector: (value: T) => Rx.IPromise<TResult>
Returns
Observable
Parameters
Returns
Observable
Parameters
Returns
Observable
public selectSwitch( selector: (value: T, index: number, source: Rx.Observable<T>) => TResult , thisArg?: any ) : Observable Projects each element of an observable sequence into a new sequence of observable sequences by incorporating the element's index and then
transforms an observable sequence of observable sequences into an observable sequence producing values only from the most recent observable sequence.
Parameters
Returns
Observable
An observable sequence whose elements are the result of invoking the transform function on each element of source producing an Observable of Observable sequences
and that at any point in time produces the elements of the most recent inner observable sequence that has been received.
Returns an observable sequence that shares a single subscription to the underlying sequence.
This operator is a specialization of publish which creates a subscription when the number of observers goes from zero to one, then shares that subscription with all subsequent observers until the number of observers returns to zero, at which point the subscription is disposed.
Returns
Observable
An observable sequence that contains the elements of a sequence produced by multicasting the source sequence.
public shareReplay( bufferSize?: number , window?: number , scheduler?: IScheduler ) : Observable Parameters
bufferSize?: number optional
window?: number optional
scheduler?: IScheduler optional
Returns
Observable
public shareValue( initialValue: T in Rx.Observable<T> ) : Observable Returns an observable sequence that shares a single subscription to the underlying sequence and starts with an initialValue.
This operator is a specialization of publishValue which creates a subscription when the number of observers goes from zero to one, then shares that subscription with all subsequent observers until the number of observers returns to zero, at which point the subscription is disposed.
Parameters
Returns
Observable
An observable sequence that contains the elements of a sequence produced by multicasting the source sequence.
public skipWhile( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg?: any ) : Observable Parameters
predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean
thisArg?: any optional
Returns
Observable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
public switch( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
public switchLatest( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
public takeWhile( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg?: any ) : Observable Parameters
predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean
thisArg?: any optional
Returns
Observable
public throttleWithSelector( throttleDurationSelector: (item: T) => Rx.Observable<TTimeout> ) : Observable Parameters
throttleDurationSelector: (item: T) => Rx.Observable<TTimeout>
Returns
Observable
public timeoutWithSelector( firstTimeout: Observable , timeoutdurationSelector?: (item: T) => Rx.Observable<TTimeout> , other?: Observable ) : Observable Parameters
timeoutdurationSelector?: (item: T) => Rx.Observable<TTimeout> optional
Returns
Observable
public toPromise( promiseCtor: new(resolver: (resolvePromise: (value: T) => void, rejectPromise: (reason: any) => void) => void) => TPromise ) : TPromise Converts an existing observable sequence to an ES6 Compatible Promise
Parameters
Returns
TPromise
An ES6 compatible promise with the last value from the observable sequence.
public toPromise( promiseCtor?: new(resolver: (resolvePromise: (value: T) => void, rejectPromise: (reason: any) => void) => void) => Rx.IPromise<T> ) : IPromise Converts an existing observable sequence to an ES6 Compatible Promise
Parameters
promiseCtor?: new(resolver: (resolvePromise: (value: T) => void, rejectPromise: (reason: any) => void) => void) => Rx.IPromise<T> optional
Returns
IPromise
An ES6 compatible promise with the last value from the observable sequence.
public where( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg?: any ) : Observable Parameters
predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean
thisArg?: any optional
Returns
Observable
public zip( second: Observable , resultSelector: (v1: T, v2: T2) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2) => TResult
Returns
Observable
public zip( second: IPromise , resultSelector: (v1: T, v2: T2) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2) => TResult
Returns
Observable
public zip( second: Observable , third: Observable , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public zip( second: Observable , third: IPromise , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public zip( second: IPromise , third: Observable , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public zip( second: IPromise , third: IPromise , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public zip( second: Observable , third: Observable , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: Observable , third: Observable , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: Observable , third: IPromise , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: Observable , third: IPromise , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: IPromise , third: Observable , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: IPromise , third: Observable , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: IPromise , third: IPromise , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: IPromise , third: IPromise , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: Observable , third: Observable , fourth: Observable , fifth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult
Returns
Observable
public zip( second: Observable [] , resultSelector: (left: T, ...right: TOther[]) => TResult ) : Observable Parameters
resultSelector: (left: T, ...right: TOther[]) => TResult
Returns
Observable
public zip( second: IPromise [] , resultSelector: (left: T, ...right: TOther[]) => TResult ) : Observable Parameters
resultSelector: (left: T, ...right: TOther[]) => TResult
Returns
Observable
Defined in rx.binding-lite.d.ts:17
Defined in rx.binding-lite.d.ts:24
public catch( handler: (exception: any) => Rx.Observable<T> ) : Observable Parameters
handler: (exception: any) => Rx.Observable<T>
Returns
Observable
public catch( handler: (exception: any) => Rx.IPromise<T> ) : Observable Parameters
handler: (exception: any) => Rx.IPromise<T>
Returns
Observable
Parameters
Returns
Observable
public catchException( handler: (exception: any) => Rx.Observable<T> ) : Observable Parameters
handler: (exception: any) => Rx.Observable<T>
Returns
Observable
public catchException( handler: (exception: any) => Rx.IPromise<T> ) : Observable Parameters
handler: (exception: any) => Rx.IPromise<T>
Returns
Observable
Parameters
Returns
Observable
public combineLatest( second: Observable , resultSelector: (v1: T, v2: T2) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2) => TResult
Returns
Observable
public combineLatest( second: IPromise , resultSelector: (v1: T, v2: T2) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2) => TResult
Returns
Observable
public combineLatest( second: Observable , third: Observable , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public combineLatest( second: Observable , third: IPromise , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: Observable , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: IPromise , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public combineLatest( second: Observable , third: Observable , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: Observable , third: Observable , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: Observable , third: IPromise , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: Observable , third: IPromise , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: Observable , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: Observable , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: IPromise , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: IPromise , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: Observable , third: Observable , fourth: Observable , fifth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult
Returns
Observable
public combineLatest( souces: Observable [] , resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult ) : Observable Parameters
resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult
Returns
Observable
public combineLatest( souces: IPromise [] , resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult ) : Observable Parameters
resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult
Returns
Observable
public concatAll( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
public concatMap( selector: (value: T, index: number) => Rx.Observable<T2> , resultSelector: (value1: T, value2: T2, index: number) => R ) : Observable Parameters
selector: (value: T, index: number) => Rx.Observable<T2>
resultSelector: (value1: T, value2: T2, index: number) => R
Returns
Observable
public concatMap( selector: (value: T, index: number) => Rx.IPromise<T2> , resultSelector: (value1: T, value2: T2, index: number) => R ) : Observable Parameters
selector: (value: T, index: number) => Rx.IPromise<T2>
resultSelector: (value1: T, value2: T2, index: number) => R
Returns
Observable
public concatMap( selector: (value: T, index: number) => Rx.Observable<R> ) : Observable Parameters
selector: (value: T, index: number) => Rx.Observable<R>
Returns
Observable
public concatMap( selector: (value: T, index: number) => Rx.IPromise<R> ) : Observable Parameters
selector: (value: T, index: number) => Rx.IPromise<R>
Returns
Observable
Parameters
Returns
Observable
public concatObservable( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
public controlled( enableQueue?: boolean ) : ControlledObservable Attaches a controller to the observable sequence with the ability to queue.
Parameters
enableQueue?: boolean optional
Returns
ControlledObservable
public delayWithSelector( delayDurationSelector: (item: T) => number ) : Observable Parameters
delayDurationSelector: (item: T) => number
Returns
Observable
public delayWithSelector( subscriptionDelay: number , delayDurationSelector: (item: T) => number ) : Observable Parameters
subscriptionDelay: number
delayDurationSelector: (item: T) => number
Returns
Observable
public distinctUntilChanged( skipParameter: boolean , comparer: (x: T, y: T) => boolean ) : Observable Parameters
skipParameter: boolean
comparer: (x: T, y: T) => boolean
Returns
Observable
public distinctUntilChanged( keySelector?: (value: T) => TValue , comparer?: (x: TValue, y: TValue) => boolean ) : Observable Parameters
keySelector?: (value: T) => TValue optional
comparer?: (x: TValue, y: TValue) => boolean optional
Returns
Observable
Parameters
Returns
Observable
public do( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : Observable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
Observable
Parameters
Returns
Observable
public doAction( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : Observable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
Observable
public filter( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg?: any ) : Observable Parameters
predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean
thisArg?: any optional
Returns
Observable
public flatMap( selector: (value: T) => Rx.Observable<TOther> , resultSelector: (item: T, other: TOther) => TResult ) : Observable Parameters
selector: (value: T) => Rx.Observable<TOther>
resultSelector: (item: T, other: TOther) => TResult
Returns
Observable
public flatMap( selector: (value: T) => Rx.IPromise<TOther> , resultSelector: (item: T, other: TOther) => TResult ) : Observable Parameters
selector: (value: T) => Rx.IPromise<TOther>
resultSelector: (item: T, other: TOther) => TResult
Returns
Observable
public flatMap( selector: (value: T) => Rx.Observable<TResult> ) : Observable Parameters
selector: (value: T) => Rx.Observable<TResult>
Returns
Observable
public flatMap( selector: (value: T) => Rx.IPromise<TResult> ) : Observable Parameters
selector: (value: T) => Rx.IPromise<TResult>
Returns
Observable
Parameters
Returns
Observable
Parameters
Returns
Observable
public flatMapLatest( selector: (value: T, index: number, source: Rx.Observable<T>) => TResult , thisArg?: any ) : Observable Projects each element of an observable sequence into a new sequence of observable sequences by incorporating the element's index and then
transforms an observable sequence of observable sequences into an observable sequence producing values only from the most recent observable sequence.
Parameters
Returns
Observable
An observable sequence whose elements are the result of invoking the transform function on each element of source producing an Observable of Observable sequences
and that at any point in time produces the elements of the most recent inner observable sequence that has been received.
public forEach( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
public hasObservers( ) : boolean Returns
boolean
public map( selector: (value: T, index: number, source: Rx.Observable<T>) => TResult , thisArg?: any ) : Observable Parameters
selector: (value: T, index: number, source: Rx.Observable<T>) => TResult
thisArg?: any optional
Returns
Observable
public merge( maxConcurrent: number ) : T in Rx.Observable<T> Parameters
Returns
T in Rx.Observable<T>
Parameters
Returns
Observable
Parameters
Returns
Observable
public mergeAll( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
public mergeObservable( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
Parameters
Returns
ConnectableObservable
public multicast( subjectSelector: () => Rx.ISubject<T> , selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<T> ) : Observable Parameters
subjectSelector: () => Rx.ISubject<T>
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<T>
Returns
Observable
public onError( exception: any ) Parameters
public onNext( value: T in Rx.IObserver<T> ) Parameters
value: T in Rx.IObserver<T>
Returns a new observable that triggers on the second and subsequent triggerings of the input observable.
The Nth triggering of the input observable passes the arguments from the N-1th and Nth triggering as a pair.
The argument passed to the N-1th triggering is held in hidden internal state until the Nth triggering occurs.
Returns
Observable
An observable that triggers on successive pairs of observations from the input observable as an array.
public partition( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg: any ) : Observable [] Returns two observables which partition the observations of the source by the given function.
The first will trigger observations for those values for which the predicate returns true.
The second will trigger observations for those values where the predicate returns false.
The predicate is executed once for each subscribed observer.
Both also propagate all error observations arising from the source and each completes
when the source completes.
Parameters
Returns
Observable []
An array of observables. The first triggers when the predicate returns true,
and the second triggers when the predicate returns false.
Pauses the underlying observable sequence based upon the observable sequence which yields true/false.
Parameters
Returns
Observable
The observable sequence which is paused based upon the pauser.
Parameters
Returns
PausableObservable
Pauses the underlying observable sequence based upon the observable sequence which yields true/false,
and yields the values that were buffered while paused.
Parameters
Returns
PausableObservable
The observable sequence which is paused based upon the pauser.
Returns
ConnectableObservable
public publish( selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult> ) : Observable Parameters
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult>
Returns
Observable
Returns
ConnectableObservable
public publishLast( selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult> ) : Observable Parameters
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult>
Returns
Observable
public publishValue( initialValue: T in Rx.Observable<T> ) : ConnectableObservable Parameters
initialValue: T in Rx.Observable<T>
Returns
ConnectableObservable
public publishValue( selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult> , initialValue: T in Rx.Observable<T> ) : Observable Parameters
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult>
initialValue: T in Rx.Observable<T>
Returns
Observable
public repeat( repeatCount?: number ) : Observable Parameters
repeatCount?: number optional
Returns
Observable
public replay( selector?: boolean , bufferSize?: number , window?: number , scheduler?: IScheduler ) : ConnectableObservable Parameters
selector?: boolean optional
bufferSize?: number optional
window?: number optional
scheduler?: IScheduler optional
Returns
ConnectableObservable
public replay( selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<T> , bufferSize?: number , window?: number , scheduler?: IScheduler ) : Observable Parameters
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<T>
bufferSize?: number optional
window?: number optional
scheduler?: IScheduler optional
Returns
Observable
public retry( retryCount?: number ) : Observable Parameters
retryCount?: number optional
Returns
Observable
public scan( seed: TAcc , accumulator: (acc: TAcc, value: T) => TAcc ) : Observable Parameters
seed: TAcc
accumulator: (acc: TAcc, value: T) => TAcc
Returns
Observable
public scan( accumulator: (acc: T, value: T) => T ) : Observable Parameters
accumulator: (acc: T, value: T) => T
Returns
Observable
public select( selector: (value: T, index: number, source: Rx.Observable<T>) => TResult , thisArg?: any ) : Observable Parameters
selector: (value: T, index: number, source: Rx.Observable<T>) => TResult
thisArg?: any optional
Returns
Observable
public selectConcat( selector: (value: T, index: number) => Rx.Observable<T2> , resultSelector: (value1: T, value2: T2, index: number) => R ) : Observable Parameters
selector: (value: T, index: number) => Rx.Observable<T2>
resultSelector: (value1: T, value2: T2, index: number) => R
Returns
Observable
public selectConcat( selector: (value: T, index: number) => Rx.IPromise<T2> , resultSelector: (value1: T, value2: T2, index: number) => R ) : Observable Parameters
selector: (value: T, index: number) => Rx.IPromise<T2>
resultSelector: (value1: T, value2: T2, index: number) => R
Returns
Observable
public selectConcat( selector: (value: T, index: number) => Rx.Observable<R> ) : Observable Parameters
selector: (value: T, index: number) => Rx.Observable<R>
Returns
Observable
public selectConcat( selector: (value: T, index: number) => Rx.IPromise<R> ) : Observable Parameters
selector: (value: T, index: number) => Rx.IPromise<R>
Returns
Observable
Parameters
Returns
Observable
public selectMany( selector: (value: T) => Rx.Observable<TOther> , resultSelector: (item: T, other: TOther) => TResult ) : Observable Parameters
selector: (value: T) => Rx.Observable<TOther>
resultSelector: (item: T, other: TOther) => TResult
Returns
Observable
public selectMany( selector: (value: T) => Rx.IPromise<TOther> , resultSelector: (item: T, other: TOther) => TResult ) : Observable Parameters
selector: (value: T) => Rx.IPromise<TOther>
resultSelector: (item: T, other: TOther) => TResult
Returns
Observable
public selectMany( selector: (value: T) => Rx.Observable<TResult> ) : Observable Parameters
selector: (value: T) => Rx.Observable<TResult>
Returns
Observable
public selectMany( selector: (value: T) => Rx.IPromise<TResult> ) : Observable Parameters
selector: (value: T) => Rx.IPromise<TResult>
Returns
Observable
Parameters
Returns
Observable
Parameters
Returns
Observable
public selectSwitch( selector: (value: T, index: number, source: Rx.Observable<T>) => TResult , thisArg?: any ) : Observable Projects each element of an observable sequence into a new sequence of observable sequences by incorporating the element's index and then
transforms an observable sequence of observable sequences into an observable sequence producing values only from the most recent observable sequence.
Parameters
Returns
Observable
An observable sequence whose elements are the result of invoking the transform function on each element of source producing an Observable of Observable sequences
and that at any point in time produces the elements of the most recent inner observable sequence that has been received.
Returns an observable sequence that shares a single subscription to the underlying sequence.
This operator is a specialization of publish which creates a subscription when the number of observers goes from zero to one, then shares that subscription with all subsequent observers until the number of observers returns to zero, at which point the subscription is disposed.
Returns
Observable
An observable sequence that contains the elements of a sequence produced by multicasting the source sequence.
public shareReplay( bufferSize?: number , window?: number , scheduler?: IScheduler ) : Observable Parameters
bufferSize?: number optional
window?: number optional
scheduler?: IScheduler optional
Returns
Observable
public shareValue( initialValue: T in Rx.Observable<T> ) : Observable Returns an observable sequence that shares a single subscription to the underlying sequence and starts with an initialValue.
This operator is a specialization of publishValue which creates a subscription when the number of observers goes from zero to one, then shares that subscription with all subsequent observers until the number of observers returns to zero, at which point the subscription is disposed.
Parameters
Returns
Observable
An observable sequence that contains the elements of a sequence produced by multicasting the source sequence.
public skipWhile( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg?: any ) : Observable Parameters
predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean
thisArg?: any optional
Returns
Observable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
public switch( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
public switchLatest( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
public takeWhile( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg?: any ) : Observable Parameters
predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean
thisArg?: any optional
Returns
Observable
public throttleWithSelector( throttleDurationSelector: (item: T) => Rx.Observable<TTimeout> ) : Observable Parameters
throttleDurationSelector: (item: T) => Rx.Observable<TTimeout>
Returns
Observable
public timeoutWithSelector( firstTimeout: Observable , timeoutdurationSelector?: (item: T) => Rx.Observable<TTimeout> , other?: Observable ) : Observable Parameters
timeoutdurationSelector?: (item: T) => Rx.Observable<TTimeout> optional
Returns
Observable
public toNotifier( ) : (notification: Rx.Notification<T>) => void Returns
(notification: Rx.Notification<T>) => void
public toPromise( promiseCtor: new(resolver: (resolvePromise: (value: T) => void, rejectPromise: (reason: any) => void) => void) => TPromise ) : TPromise Converts an existing observable sequence to an ES6 Compatible Promise
Parameters
Returns
TPromise
An ES6 compatible promise with the last value from the observable sequence.
public toPromise( promiseCtor?: new(resolver: (resolvePromise: (value: T) => void, rejectPromise: (reason: any) => void) => void) => Rx.IPromise<T> ) : IPromise Converts an existing observable sequence to an ES6 Compatible Promise
Parameters
promiseCtor?: new(resolver: (resolvePromise: (value: T) => void, rejectPromise: (reason: any) => void) => void) => Rx.IPromise<T> optional
Returns
IPromise
An ES6 compatible promise with the last value from the observable sequence.
public where( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg?: any ) : Observable Parameters
predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean
thisArg?: any optional
Returns
Observable
public zip( second: Observable , resultSelector: (v1: T, v2: T2) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2) => TResult
Returns
Observable
public zip( second: IPromise , resultSelector: (v1: T, v2: T2) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2) => TResult
Returns
Observable
public zip( second: Observable , third: Observable , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public zip( second: Observable , third: IPromise , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public zip( second: IPromise , third: Observable , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public zip( second: IPromise , third: IPromise , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public zip( second: Observable , third: Observable , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: Observable , third: Observable , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: Observable , third: IPromise , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: Observable , third: IPromise , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: IPromise , third: Observable , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: IPromise , third: Observable , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: IPromise , third: IPromise , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: IPromise , third: IPromise , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: Observable , third: Observable , fourth: Observable , fifth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult
Returns
Observable
public zip( second: Observable [] , resultSelector: (left: T, ...right: TOther[]) => TResult ) : Observable Parameters
resultSelector: (left: T, ...right: TOther[]) => TResult
Returns
Observable
public zip( second: IPromise [] , resultSelector: (left: T, ...right: TOther[]) => TResult ) : Observable Parameters
resultSelector: (left: T, ...right: TOther[]) => TResult
Returns
Observable
Defined in rx-lite.d.ts:490
Defined in rx-lite.d.ts:498
public catch( handler: (exception: any) => Rx.Observable<T> ) : Observable Parameters
handler: (exception: any) => Rx.Observable<T>
Returns
Observable
public catch( handler: (exception: any) => Rx.IPromise<T> ) : Observable Parameters
handler: (exception: any) => Rx.IPromise<T>
Returns
Observable
Parameters
Returns
Observable
public catchException( handler: (exception: any) => Rx.Observable<T> ) : Observable Parameters
handler: (exception: any) => Rx.Observable<T>
Returns
Observable
public catchException( handler: (exception: any) => Rx.IPromise<T> ) : Observable Parameters
handler: (exception: any) => Rx.IPromise<T>
Returns
Observable
Parameters
Returns
Observable
public combineLatest( second: Observable , resultSelector: (v1: T, v2: T2) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2) => TResult
Returns
Observable
public combineLatest( second: IPromise , resultSelector: (v1: T, v2: T2) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2) => TResult
Returns
Observable
public combineLatest( second: Observable , third: Observable , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public combineLatest( second: Observable , third: IPromise , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: Observable , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: IPromise , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public combineLatest( second: Observable , third: Observable , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: Observable , third: Observable , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: Observable , third: IPromise , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: Observable , third: IPromise , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: Observable , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: Observable , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: IPromise , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: IPromise , third: IPromise , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public combineLatest( second: Observable , third: Observable , fourth: Observable , fifth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult
Returns
Observable
public combineLatest( souces: Observable [] , resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult ) : Observable Parameters
resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult
Returns
Observable
public combineLatest( souces: IPromise [] , resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult ) : Observable Parameters
resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult
Returns
Observable
public concatAll( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
public concatMap( selector: (value: T, index: number) => Rx.Observable<T2> , resultSelector: (value1: T, value2: T2, index: number) => R ) : Observable Parameters
selector: (value: T, index: number) => Rx.Observable<T2>
resultSelector: (value1: T, value2: T2, index: number) => R
Returns
Observable
public concatMap( selector: (value: T, index: number) => Rx.IPromise<T2> , resultSelector: (value1: T, value2: T2, index: number) => R ) : Observable Parameters
selector: (value: T, index: number) => Rx.IPromise<T2>
resultSelector: (value1: T, value2: T2, index: number) => R
Returns
Observable
public concatMap( selector: (value: T, index: number) => Rx.Observable<R> ) : Observable Parameters
selector: (value: T, index: number) => Rx.Observable<R>
Returns
Observable
public concatMap( selector: (value: T, index: number) => Rx.IPromise<R> ) : Observable Parameters
selector: (value: T, index: number) => Rx.IPromise<R>
Returns
Observable
Parameters
Returns
Observable
public concatObservable( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
public controlled( enableQueue?: boolean ) : ControlledObservable Attaches a controller to the observable sequence with the ability to queue.
Parameters
enableQueue?: boolean optional
Returns
ControlledObservable
public delayWithSelector( delayDurationSelector: (item: T) => number ) : Observable Parameters
delayDurationSelector: (item: T) => number
Returns
Observable
public delayWithSelector( subscriptionDelay: number , delayDurationSelector: (item: T) => number ) : Observable Parameters
subscriptionDelay: number
delayDurationSelector: (item: T) => number
Returns
Observable
public distinctUntilChanged( skipParameter: boolean , comparer: (x: T, y: T) => boolean ) : Observable Parameters
skipParameter: boolean
comparer: (x: T, y: T) => boolean
Returns
Observable
public distinctUntilChanged( keySelector?: (value: T) => TValue , comparer?: (x: TValue, y: TValue) => boolean ) : Observable Parameters
keySelector?: (value: T) => TValue optional
comparer?: (x: TValue, y: TValue) => boolean optional
Returns
Observable
Parameters
Returns
Observable
public do( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : Observable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
Observable
Parameters
Returns
Observable
public doAction( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : Observable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
Observable
public filter( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg?: any ) : Observable Parameters
predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean
thisArg?: any optional
Returns
Observable
public flatMap( selector: (value: T) => Rx.Observable<TOther> , resultSelector: (item: T, other: TOther) => TResult ) : Observable Parameters
selector: (value: T) => Rx.Observable<TOther>
resultSelector: (item: T, other: TOther) => TResult
Returns
Observable
public flatMap( selector: (value: T) => Rx.IPromise<TOther> , resultSelector: (item: T, other: TOther) => TResult ) : Observable Parameters
selector: (value: T) => Rx.IPromise<TOther>
resultSelector: (item: T, other: TOther) => TResult
Returns
Observable
public flatMap( selector: (value: T) => Rx.Observable<TResult> ) : Observable Parameters
selector: (value: T) => Rx.Observable<TResult>
Returns
Observable
public flatMap( selector: (value: T) => Rx.IPromise<TResult> ) : Observable Parameters
selector: (value: T) => Rx.IPromise<TResult>
Returns
Observable
Parameters
Returns
Observable
Parameters
Returns
Observable
public flatMapLatest( selector: (value: T, index: number, source: Rx.Observable<T>) => TResult , thisArg?: any ) : Observable Projects each element of an observable sequence into a new sequence of observable sequences by incorporating the element's index and then
transforms an observable sequence of observable sequences into an observable sequence producing values only from the most recent observable sequence.
Parameters
Returns
Observable
An observable sequence whose elements are the result of invoking the transform function on each element of source producing an Observable of Observable sequences
and that at any point in time produces the elements of the most recent inner observable sequence that has been received.
public forEach( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
public hasObservers( ) : boolean Returns
boolean
public map( selector: (value: T, index: number, source: Rx.Observable<T>) => TResult , thisArg?: any ) : Observable Parameters
selector: (value: T, index: number, source: Rx.Observable<T>) => TResult
thisArg?: any optional
Returns
Observable
public merge( maxConcurrent: number ) : T in Rx.Observable<T> Parameters
Returns
T in Rx.Observable<T>
Parameters
Returns
Observable
Parameters
Returns
Observable
public mergeAll( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
public mergeObservable( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
Parameters
Returns
ConnectableObservable
public multicast( subjectSelector: () => Rx.ISubject<T> , selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<T> ) : Observable Parameters
subjectSelector: () => Rx.ISubject<T>
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<T>
Returns
Observable
public onError( exception: any ) Parameters
public onNext( value: T in Rx.IObserver<T> ) Parameters
value: T in Rx.IObserver<T>
Returns a new observable that triggers on the second and subsequent triggerings of the input observable.
The Nth triggering of the input observable passes the arguments from the N-1th and Nth triggering as a pair.
The argument passed to the N-1th triggering is held in hidden internal state until the Nth triggering occurs.
Returns
Observable
An observable that triggers on successive pairs of observations from the input observable as an array.
public partition( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg: any ) : Observable [] Returns two observables which partition the observations of the source by the given function.
The first will trigger observations for those values for which the predicate returns true.
The second will trigger observations for those values where the predicate returns false.
The predicate is executed once for each subscribed observer.
Both also propagate all error observations arising from the source and each completes
when the source completes.
Parameters
Returns
Observable []
An array of observables. The first triggers when the predicate returns true,
and the second triggers when the predicate returns false.
Pauses the underlying observable sequence based upon the observable sequence which yields true/false.
Parameters
Returns
Observable
The observable sequence which is paused based upon the pauser.
Parameters
Returns
PausableObservable
Pauses the underlying observable sequence based upon the observable sequence which yields true/false,
and yields the values that were buffered while paused.
Parameters
Returns
PausableObservable
The observable sequence which is paused based upon the pauser.
Returns
ConnectableObservable
public publish( selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult> ) : Observable Parameters
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult>
Returns
Observable
Returns
ConnectableObservable
public publishLast( selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult> ) : Observable Parameters
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult>
Returns
Observable
public publishValue( initialValue: T in Rx.Observable<T> ) : ConnectableObservable Parameters
initialValue: T in Rx.Observable<T>
Returns
ConnectableObservable
public publishValue( selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult> , initialValue: T in Rx.Observable<T> ) : Observable Parameters
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult>
initialValue: T in Rx.Observable<T>
Returns
Observable
public repeat( repeatCount?: number ) : Observable Parameters
repeatCount?: number optional
Returns
Observable
public replay( selector?: boolean , bufferSize?: number , window?: number , scheduler?: IScheduler ) : ConnectableObservable Parameters
selector?: boolean optional
bufferSize?: number optional
window?: number optional
scheduler?: IScheduler optional
Returns
ConnectableObservable
public replay( selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<T> , bufferSize?: number , window?: number , scheduler?: IScheduler ) : Observable Parameters
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<T>
bufferSize?: number optional
window?: number optional
scheduler?: IScheduler optional
Returns
Observable
public retry( retryCount?: number ) : Observable Parameters
retryCount?: number optional
Returns
Observable
public scan( seed: TAcc , accumulator: (acc: TAcc, value: T) => TAcc ) : Observable Parameters
seed: TAcc
accumulator: (acc: TAcc, value: T) => TAcc
Returns
Observable
public scan( accumulator: (acc: T, value: T) => T ) : Observable Parameters
accumulator: (acc: T, value: T) => T
Returns
Observable
public select( selector: (value: T, index: number, source: Rx.Observable<T>) => TResult , thisArg?: any ) : Observable Parameters
selector: (value: T, index: number, source: Rx.Observable<T>) => TResult
thisArg?: any optional
Returns
Observable
public selectConcat( selector: (value: T, index: number) => Rx.Observable<T2> , resultSelector: (value1: T, value2: T2, index: number) => R ) : Observable Parameters
selector: (value: T, index: number) => Rx.Observable<T2>
resultSelector: (value1: T, value2: T2, index: number) => R
Returns
Observable
public selectConcat( selector: (value: T, index: number) => Rx.IPromise<T2> , resultSelector: (value1: T, value2: T2, index: number) => R ) : Observable Parameters
selector: (value: T, index: number) => Rx.IPromise<T2>
resultSelector: (value1: T, value2: T2, index: number) => R
Returns
Observable
public selectConcat( selector: (value: T, index: number) => Rx.Observable<R> ) : Observable Parameters
selector: (value: T, index: number) => Rx.Observable<R>
Returns
Observable
public selectConcat( selector: (value: T, index: number) => Rx.IPromise<R> ) : Observable Parameters
selector: (value: T, index: number) => Rx.IPromise<R>
Returns
Observable
Parameters
Returns
Observable
public selectMany( selector: (value: T) => Rx.Observable<TOther> , resultSelector: (item: T, other: TOther) => TResult ) : Observable Parameters
selector: (value: T) => Rx.Observable<TOther>
resultSelector: (item: T, other: TOther) => TResult
Returns
Observable
public selectMany( selector: (value: T) => Rx.IPromise<TOther> , resultSelector: (item: T, other: TOther) => TResult ) : Observable Parameters
selector: (value: T) => Rx.IPromise<TOther>
resultSelector: (item: T, other: TOther) => TResult
Returns
Observable
public selectMany( selector: (value: T) => Rx.Observable<TResult> ) : Observable Parameters
selector: (value: T) => Rx.Observable<TResult>
Returns
Observable
public selectMany( selector: (value: T) => Rx.IPromise<TResult> ) : Observable Parameters
selector: (value: T) => Rx.IPromise<TResult>
Returns
Observable
Parameters
Returns
Observable
Parameters
Returns
Observable
public selectSwitch( selector: (value: T, index: number, source: Rx.Observable<T>) => TResult , thisArg?: any ) : Observable Projects each element of an observable sequence into a new sequence of observable sequences by incorporating the element's index and then
transforms an observable sequence of observable sequences into an observable sequence producing values only from the most recent observable sequence.
Parameters
Returns
Observable
An observable sequence whose elements are the result of invoking the transform function on each element of source producing an Observable of Observable sequences
and that at any point in time produces the elements of the most recent inner observable sequence that has been received.
Returns an observable sequence that shares a single subscription to the underlying sequence.
This operator is a specialization of publish which creates a subscription when the number of observers goes from zero to one, then shares that subscription with all subsequent observers until the number of observers returns to zero, at which point the subscription is disposed.
Returns
Observable
An observable sequence that contains the elements of a sequence produced by multicasting the source sequence.
public shareReplay( bufferSize?: number , window?: number , scheduler?: IScheduler ) : Observable Parameters
bufferSize?: number optional
window?: number optional
scheduler?: IScheduler optional
Returns
Observable
public shareValue( initialValue: T in Rx.Observable<T> ) : Observable Returns an observable sequence that shares a single subscription to the underlying sequence and starts with an initialValue.
This operator is a specialization of publishValue which creates a subscription when the number of observers goes from zero to one, then shares that subscription with all subsequent observers until the number of observers returns to zero, at which point the subscription is disposed.
Parameters
Returns
Observable
An observable sequence that contains the elements of a sequence produced by multicasting the source sequence.
public skipWhile( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg?: any ) : Observable Parameters
predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean
thisArg?: any optional
Returns
Observable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
Parameters
Returns
IDisposable
public subscribe( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : IDisposable Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
IDisposable
public switch( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
public switchLatest( ) : T in Rx.Observable<T> Returns
T in Rx.Observable<T>
public takeWhile( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg?: any ) : Observable Parameters
predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean
thisArg?: any optional
Returns
Observable
public throttleWithSelector( throttleDurationSelector: (item: T) => Rx.Observable<TTimeout> ) : Observable Parameters
throttleDurationSelector: (item: T) => Rx.Observable<TTimeout>
Returns
Observable
public timeoutWithSelector( firstTimeout: Observable , timeoutdurationSelector?: (item: T) => Rx.Observable<TTimeout> , other?: Observable ) : Observable Parameters
timeoutdurationSelector?: (item: T) => Rx.Observable<TTimeout> optional
Returns
Observable
public toNotifier( ) : (notification: Rx.Notification<T>) => void Returns
(notification: Rx.Notification<T>) => void
public toPromise( promiseCtor: new(resolver: (resolvePromise: (value: T) => void, rejectPromise: (reason: any) => void) => void) => TPromise ) : TPromise Converts an existing observable sequence to an ES6 Compatible Promise
Parameters
Returns
TPromise
An ES6 compatible promise with the last value from the observable sequence.
public toPromise( promiseCtor?: new(resolver: (resolvePromise: (value: T) => void, rejectPromise: (reason: any) => void) => void) => Rx.IPromise<T> ) : IPromise Converts an existing observable sequence to an ES6 Compatible Promise
Parameters
promiseCtor?: new(resolver: (resolvePromise: (value: T) => void, rejectPromise: (reason: any) => void) => void) => Rx.IPromise<T> optional
Returns
IPromise
An ES6 compatible promise with the last value from the observable sequence.
public where( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg?: any ) : Observable Parameters
predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean
thisArg?: any optional
Returns
Observable
public zip( second: Observable , resultSelector: (v1: T, v2: T2) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2) => TResult
Returns
Observable
public zip( second: IPromise , resultSelector: (v1: T, v2: T2) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2) => TResult
Returns
Observable
public zip( second: Observable , third: Observable , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public zip( second: Observable , third: IPromise , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public zip( second: IPromise , third: Observable , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public zip( second: IPromise , third: IPromise , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3) => TResult
Returns
Observable
public zip( second: Observable , third: Observable , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: Observable , third: Observable , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: Observable , third: IPromise , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: Observable , third: IPromise , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: IPromise , third: Observable , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: IPromise , third: Observable , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: IPromise , third: IPromise , fourth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: IPromise , third: IPromise , fourth: IPromise , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
Returns
Observable
public zip( second: Observable , third: Observable , fourth: Observable , fifth: Observable , resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult ) : Observable Parameters
resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult
Returns
Observable
public zip( second: Observable [] , resultSelector: (left: T, ...right: TOther[]) => TResult ) : Observable Parameters
resultSelector: (left: T, ...right: TOther[]) => TResult
Returns
Observable
public zip( second: IPromise [] , resultSelector: (left: T, ...right: TOther[]) => TResult ) : Observable Parameters
resultSelector: (left: T, ...right: TOther[]) => TResult
Returns
Observable