Methods
public catch( handler: (exception: any) => Rx.Observable<T> ) : Observable
Defined in rx-lite.d.ts:202
Parameters
handler: (exception: any) => Rx.Observable<T>
Returns
Observable
public catch( handler: (exception: any) => Rx.IPromise<T> ) : Observable
Defined in rx-lite.d.ts:204
Parameters
handler: (exception: any) => Rx.IPromise<T>
Returns
Observable
Defined in rx-lite.d.ts:206
Parameters
Returns
Observable
public catchException( handler: (exception: any) => Rx.Observable<T> ) : Observable
Defined in rx-lite.d.ts:203
Parameters
handler: (exception: any) => Rx.Observable<T>
Returns
Observable
public catchException( handler: (exception: any) => Rx.IPromise<T> ) : Observable
Defined in rx-lite.d.ts:205
Parameters
handler: (exception: any) => Rx.IPromise<T>
Returns
Observable
Defined in rx-lite.d.ts:207
Parameters
Returns
Observable
public combineLatest( second: Observable , resultSelector: (v1: T, v2: T2) => TResult ) : Observable
Defined in rx-lite.d.ts:208
Parameters
resultSelector: (v1: T, v2: T2) => TResult
Returns
Observable
public combineLatest( second: IPromise , resultSelector: (v1: T, v2: T2) => TResult ) : Observable
Defined in rx-lite.d.ts:209
Parameters
resultSelector: (v1: T, v2: T2) => TResult
Returns
Observable
public combineLatest( second: Observable , third: Observable , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable
Defined in rx-lite.d.ts:210
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
Defined in rx-lite.d.ts:211
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
Defined in rx-lite.d.ts:212
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
Defined in rx-lite.d.ts:213
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
Defined in rx-lite.d.ts:214
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
Defined in rx-lite.d.ts:215
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
Defined in rx-lite.d.ts:216
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
Defined in rx-lite.d.ts:217
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
Defined in rx-lite.d.ts:218
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
Defined in rx-lite.d.ts:219
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
Defined in rx-lite.d.ts:220
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
Defined in rx-lite.d.ts:221
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
Defined in rx-lite.d.ts:222
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
Defined in rx-lite.d.ts:223
Parameters
resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult
Returns
Observable
public combineLatest( souces: IPromise [] , resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult ) : Observable
Defined in rx-lite.d.ts:224
Parameters
resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult
Returns
Observable
Defined in rx-lite.d.ts:225
Parameters
Returns
Observable
Defined in rx-lite.d.ts:226
Parameters
Returns
Observable
Defined in rx-lite.d.ts:227
Parameters
Returns
Observable
Defined in rx-lite.d.ts:228
Parameters
Returns
Observable
public concatAll( ) : T in Rx.Observable<T>
Defined in rx-lite.d.ts:229
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
Defined in rx-lite.d.ts:231
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
Defined in rx-lite.d.ts:232
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
Defined in rx-lite.d.ts:233
Parameters
selector: (value: T, index: number) => Rx.Observable<R>
Returns
Observable
public concatMap( selector: (value: T, index: number) => Rx.IPromise<R> ) : Observable
Defined in rx-lite.d.ts:234
Parameters
selector: (value: T, index: number) => Rx.IPromise<R>
Returns
Observable
Defined in rx-lite.d.ts:235
Parameters
Returns
Observable
public concatObservable( ) : T in Rx.Observable<T>
Defined in rx-lite.d.ts:230
Returns
T in Rx.Observable<T>
public controlled( enableQueue?: boolean ) : ControlledObservable
Defined in rx.backpressure-lite.d.ts:37
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
Defined in rx.time-lite.d.ts:29
Parameters
delayDurationSelector: (item: T) => number
Returns
Observable
public delayWithSelector( subscriptionDelay: number , delayDurationSelector: (item: T) => number ) : Observable
Defined in rx.time-lite.d.ts:30
Parameters
subscriptionDelay: number
delayDurationSelector: (item: T) => number
Returns
Observable
public distinctUntilChanged( skipParameter: boolean , comparer: (x: T, y: T) => boolean ) : Observable
Defined in rx-lite.d.ts:267
Parameters
skipParameter: boolean
comparer: (x: T, y: T) => boolean
Returns
Observable
public distinctUntilChanged( keySelector?: (value: T) => TValue , comparer?: (x: TValue, y: TValue) => boolean ) : Observable
Defined in rx-lite.d.ts:268
Parameters
keySelector?: (value: T) => TValue optional
comparer?: (x: TValue, y: TValue) => boolean optional
Returns
Observable
Defined in rx-lite.d.ts:269
Parameters
Returns
Observable
public do( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : Observable
Defined in rx-lite.d.ts:271
Parameters
onNext?: (value: T) => void optional
onError?: (exception: any) => void optional
onCompleted?: () => void optional
Returns
Observable
Defined in rx-lite.d.ts:270
Parameters
Returns
Observable
public doAction( onNext?: (value: T) => void , onError?: (exception: any) => void , onCompleted?: () => void ) : Observable
Defined in rx-lite.d.ts:272
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
Defined in rx-lite.d.ts:332
Parameters
predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean
thisArg?: any optional
Returns
Observable
public finally( action: () => void ) : Observable
Defined in rx-lite.d.ts:273
Parameters
Returns
Observable
public finallyAction( action: () => void ) : Observable
Defined in rx-lite.d.ts:274
Parameters
Returns
Observable
public flatMap( selector: (value: T) => Rx.Observable<TOther> , resultSelector: (item: T, other: TOther) => TResult ) : Observable
Defined in rx-lite.d.ts:295
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
Defined in rx-lite.d.ts:296
Parameters
selector: (value: T) => Rx.IPromise<TOther>
resultSelector: (item: T, other: TOther) => TResult
Returns
Observable
public flatMap( selector: (value: T) => Rx.Observable<TResult> ) : Observable
Defined in rx-lite.d.ts:297
Parameters
selector: (value: T) => Rx.Observable<TResult>
Returns
Observable
public flatMap( selector: (value: T) => Rx.IPromise<TResult> ) : Observable
Defined in rx-lite.d.ts:298
Parameters
selector: (value: T) => Rx.IPromise<TResult>
Returns
Observable
Defined in rx-lite.d.ts:299
Parameters
Returns
Observable
Defined in rx-lite.d.ts:300
Parameters
Returns
Observable
public flatMapLatest( selector: (value: T, index: number, source: Rx.Observable<T>) => TResult , thisArg?: any ) : Observable
Defined in rx-lite.d.ts:325
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
Defined in rx-lite.d.ts:199
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
Defined in rx-lite.d.ts:288
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>
Defined in rx-lite.d.ts:236
Parameters
Returns
T in Rx.Observable<T>
Defined in rx-lite.d.ts:237
Parameters
Returns
Observable
Defined in rx-lite.d.ts:238
Parameters
Returns
Observable
public mergeAll( ) : T in Rx.Observable<T>
Defined in rx-lite.d.ts:239
Returns
T in Rx.Observable<T>
public mergeObservable( ) : T in Rx.Observable<T>
Defined in rx-lite.d.ts:240
Returns
T in Rx.Observable<T>
Defined in rx.binding-lite.d.ts:38
Parameters
Returns
ConnectableObservable
public multicast( subjectSelector: () => Rx.ISubject<T> , selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<T> ) : Observable
Defined in rx.binding-lite.d.ts:39
Parameters
subjectSelector: () => Rx.ISubject<T>
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<T>
Returns
Observable
Defined in rx.coincidence-lite.d.ts:16
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 []
Defined in rx.coincidence-lite.d.ts:31
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.
Defined in rx.backpressure-lite.d.ts:17
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.
Defined in rx.backpressure-lite.d.ts:18
Parameters
Returns
PausableObservable
Defined in rx.backpressure-lite.d.ts:29
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.
Defined in rx.binding-lite.d.ts:40
Returns
ConnectableObservable
public publish( selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult> ) : Observable
Defined in rx.binding-lite.d.ts:41
Parameters
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult>
Returns
Observable
Defined in rx.binding-lite.d.ts:52
Returns
ConnectableObservable
public publishLast( selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult> ) : Observable
Defined in rx.binding-lite.d.ts:53
Parameters
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult>
Returns
Observable
public publishValue( initialValue: T in Rx.Observable<T> ) : ConnectableObservable
Defined in rx.binding-lite.d.ts:54
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
Defined in rx.binding-lite.d.ts:55
Parameters
selector: (source: Rx.ConnectableObservable<T>) => Rx.Observable<TResult>
initialValue: T in Rx.Observable<T>
Returns
Observable
public repeat( repeatCount?: number ) : Observable
Defined in rx-lite.d.ts:277
Parameters
repeatCount?: number optional
Returns
Observable
public replay( selector?: boolean , bufferSize?: number , window?: number , scheduler?: IScheduler ) : ConnectableObservable
Defined in rx.binding-lite.d.ts:67
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
Defined in rx.binding-lite.d.ts:68
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
Defined in rx-lite.d.ts:278
Parameters
retryCount?: number optional
Returns
Observable
public scan( seed: TAcc , accumulator: (acc: TAcc, value: T) => TAcc ) : Observable
Defined in rx-lite.d.ts:279
Parameters
seed: TAcc
accumulator: (acc: TAcc, value: T) => TAcc
Returns
Observable
public scan( accumulator: (acc: T, value: T) => T ) : Observable
Defined in rx-lite.d.ts:280
Parameters
accumulator: (acc: T, value: T) => T
Returns
Observable
public select( selector: (value: T, index: number, source: Rx.Observable<T>) => TResult , thisArg?: any ) : Observable
Defined in rx-lite.d.ts:287
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
Defined in rx-lite.d.ts:302
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
Defined in rx-lite.d.ts:303
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
Defined in rx-lite.d.ts:304
Parameters
selector: (value: T, index: number) => Rx.Observable<R>
Returns
Observable
public selectConcat( selector: (value: T, index: number) => Rx.IPromise<R> ) : Observable
Defined in rx-lite.d.ts:305
Parameters
selector: (value: T, index: number) => Rx.IPromise<R>
Returns
Observable
Defined in rx-lite.d.ts:306
Parameters
Returns
Observable
public selectMany( selector: (value: T) => Rx.Observable<TOther> , resultSelector: (item: T, other: TOther) => TResult ) : Observable
Defined in rx-lite.d.ts:289
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
Defined in rx-lite.d.ts:290
Parameters
selector: (value: T) => Rx.IPromise<TOther>
resultSelector: (item: T, other: TOther) => TResult
Returns
Observable
public selectMany( selector: (value: T) => Rx.Observable<TResult> ) : Observable
Defined in rx-lite.d.ts:291
Parameters
selector: (value: T) => Rx.Observable<TResult>
Returns
Observable
public selectMany( selector: (value: T) => Rx.IPromise<TResult> ) : Observable
Defined in rx-lite.d.ts:292
Parameters
selector: (value: T) => Rx.IPromise<TResult>
Returns
Observable
Defined in rx-lite.d.ts:293
Parameters
Returns
Observable
Defined in rx-lite.d.ts:294
Parameters
Returns
Observable
public selectSwitch( selector: (value: T, index: number, source: Rx.Observable<T>) => TResult , thisArg?: any ) : Observable
Defined in rx-lite.d.ts:316
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.
Defined in rx.binding-lite.d.ts:51
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
Defined in rx.lite.d.ts:47
Parameters
bufferSize?: number optional
window?: number optional
scheduler?: IScheduler optional
Returns
Observable
public shareValue( initialValue: T in Rx.Observable<T> ) : Observable
Defined in rx.binding-lite.d.ts:66
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 skipLast( count: number ) : Observable
Defined in rx-lite.d.ts:281
Parameters
Returns
Observable
Defined in rx-lite.d.ts:241
Parameters
Returns
Observable
Defined in rx-lite.d.ts:242
Parameters
Returns
Observable
public skipWhile( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg?: any ) : Observable
Defined in rx-lite.d.ts:328
Parameters
predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean
thisArg?: any optional
Returns
Observable
public startWith( values?: Array<T> ) : Observable
Defined in rx-lite.d.ts:282
Parameters
values?: Array<T> optional
Returns
Observable
public startWith( scheduler: IScheduler , values?: Array<T> ) : Observable
Defined in rx-lite.d.ts:283
Parameters
values?: Array<T> 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>
Defined in rx-lite.d.ts:243
Returns
T in Rx.Observable<T>
public switchLatest( ) : T in Rx.Observable<T>
Defined in rx-lite.d.ts:244
Returns
T in Rx.Observable<T>
public takeLastBuffer( count: number ) : Observable
Defined in rx-lite.d.ts:285
Parameters
Returns
Observable
Defined in rx-lite.d.ts:245
Parameters
Returns
Observable
Defined in rx-lite.d.ts:246
Parameters
Returns
Observable
public takeWhile( predicate: (value: T, index: number, source: Rx.Observable<T>) => boolean , thisArg?: any ) : Observable
Defined in rx-lite.d.ts:330
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
Defined in rx.time-lite.d.ts:33
Parameters
throttleDurationSelector: (item: T) => Rx.Observable<TTimeout>
Returns
Observable
Defined in rx.time-lite.d.ts:21
Parameters
Returns
Observable
Defined in rx.time-lite.d.ts:25
Parameters
Returns
Observable
Defined in rx.time-lite.d.ts:26
Parameters
Returns
Observable
public timeoutWithSelector( firstTimeout: Observable , timeoutdurationSelector?: (item: T) => Rx.Observable<TTimeout> , other?: Observable ) : Observable
Defined in rx.time-lite.d.ts:32
Parameters
timeoutdurationSelector?: (item: T) => Rx.Observable<TTimeout> optional
Returns
Observable
Defined in rx.time-lite.d.ts:22
Parameters
Returns
Observable
public toPromise( promiseCtor: new(resolver: (resolvePromise: (value: T) => void, rejectPromise: (reason: any) => void) => void) => TPromise ) : TPromise
Defined in rx-lite.d.ts:341
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
Defined in rx-lite.d.ts:353
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
Defined in rx-lite.d.ts:331
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
Defined in rx-lite.d.ts:247
Parameters
resultSelector: (v1: T, v2: T2) => TResult
Returns
Observable
public zip( second: IPromise , resultSelector: (v1: T, v2: T2) => TResult ) : Observable
Defined in rx-lite.d.ts:248
Parameters
resultSelector: (v1: T, v2: T2) => TResult
Returns
Observable
public zip( second: Observable , third: Observable , resultSelector: (v1: T, v2: T2, v3: T3) => TResult ) : Observable
Defined in rx-lite.d.ts:249
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
Defined in rx-lite.d.ts:250
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
Defined in rx-lite.d.ts:251
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
Defined in rx-lite.d.ts:252
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
Defined in rx-lite.d.ts:253
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
Defined in rx-lite.d.ts:254
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
Defined in rx-lite.d.ts:255
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
Defined in rx-lite.d.ts:256
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
Defined in rx-lite.d.ts:257
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
Defined in rx-lite.d.ts:258
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
Defined in rx-lite.d.ts:259
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
Defined in rx-lite.d.ts:260
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
Defined in rx-lite.d.ts:261
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
Defined in rx-lite.d.ts:262
Parameters
resultSelector: (left: T, ...right: TOther[]) => TResult
Returns
Observable
public zip( second: IPromise [] , resultSelector: (left: T, ...right: TOther[]) => TResult ) : Observable
Defined in rx-lite.d.ts:263
Parameters
resultSelector: (left: T, ...right: TOther[]) => TResult
Returns
Observable