Methods
Defined in rx.coincidence.d.ts:27
Parameters
Returns
Observable
public buffer( bufferClosingSelector: () => Rx.Observable<TBufferClosing> ) : Observable
Defined in rx.coincidence.d.ts:28
Parameters
bufferClosingSelector: () => Rx.Observable<TBufferClosing>
Returns
Observable
public buffer( bufferOpenings: Observable , bufferClosingSelector: () => Rx.Observable<TBufferClosing> ) : Observable
Defined in rx.coincidence.d.ts:29
Parameters
bufferClosingSelector: () => Rx.Observable<TBufferClosing>
Returns
Observable
public bufferWithCount( count: number , skip?: number ) : Observable
Parameters
count: number
skip?: number optional
Returns
Observable
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 defaultIfEmpty( defaultValue?: T in Rx.Observable<T> ) : Observable
Parameters
defaultValue?: T in Rx.Observable<T> optional
Returns
Observable
public distinct( skipParameter: boolean , valueSerializer: (value: T) => string ) : Observable
Parameters
skipParameter: boolean
valueSerializer: (value: T) => string
Returns
Observable
public distinct( keySelector?: (value: T) => TKey , keySerializer?: (key: TKey) => string ) : Observable
Parameters
keySelector?: (value: T) => TKey optional
keySerializer?: (key: TKey) => string optional
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 groupBy( keySelector: (value: T) => TKey , skipElementSelector?: boolean , keySerializer?: (key: TKey) => string ) : Observable
Parameters
keySelector: (value: T) => TKey
skipElementSelector?: boolean optional
keySerializer?: (key: TKey) => string optional
Returns
Observable
public groupBy( keySelector: (value: T) => TKey , elementSelector: (value: T) => TElement , keySerializer?: (key: TKey) => string ) : Observable
Parameters
keySelector: (value: T) => TKey
elementSelector: (value: T) => TElement
keySerializer?: (key: TKey) => string optional
Returns
Observable
public groupByUntil( keySelector: (value: T) => TKey , skipElementSelector: boolean , durationSelector: (group: Rx.GroupedObservable<TKey, T>) => Rx.Observable<TDuration> , keySerializer?: (key: TKey) => string ) : Observable
Parameters
keySelector: (value: T) => TKey
skipElementSelector: boolean
durationSelector: (group: Rx.GroupedObservable<TKey, T>) => Rx.Observable<TDuration>
keySerializer?: (key: TKey) => string optional
Returns
Observable
public groupByUntil( keySelector: (value: T) => TKey , elementSelector: (value: T) => TElement , durationSelector: (group: Rx.GroupedObservable<TKey, TElement>) => Rx.Observable<TDuration> , keySerializer?: (key: TKey) => string ) : Observable
Parameters
keySelector: (value: T) => TKey
elementSelector: (value: T) => TElement
durationSelector: (group: Rx.GroupedObservable<TKey, TElement>) => Rx.Observable<TDuration>
keySerializer?: (key: TKey) => string optional
Returns
Observable
public groupJoin( right: Observable , leftDurationSelector: (leftItem: T) => Rx.Observable<TDurationLeft> , rightDurationSelector: (rightItem: TRight) => Rx.Observable<TDurationRight> , resultSelector: (leftItem: T, rightItem: Rx.Observable<TRight>) => TResult ) : Observable
Defined in rx.coincidence.d.ts:17
Parameters
leftDurationSelector: (leftItem: T) => Rx.Observable<TDurationLeft>
rightDurationSelector: (rightItem: TRight) => Rx.Observable<TDurationRight>
resultSelector: (leftItem: T, rightItem: Rx.Observable<TRight>) => TResult
Returns
Observable
public join( right: Observable , leftDurationSelector: (leftItem: T) => Rx.Observable<TDurationLeft> , rightDurationSelector: (rightItem: TRight) => Rx.Observable<TDurationRight> , resultSelector: (leftItem: T, rightItem: TRight) => TResult ) : Observable
Defined in rx.coincidence.d.ts:11
Parameters
leftDurationSelector: (leftItem: T) => Rx.Observable<TDurationLeft>
rightDurationSelector: (rightItem: TRight) => Rx.Observable<TDurationRight>
resultSelector: (leftItem: T, rightItem: TRight) => TResult
Returns
Observable
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.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.
public repeat( repeatCount?: number ) : Observable
Defined in rx-lite.d.ts:277
Parameters
repeatCount?: number 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.
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
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 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
Defined in rx.coincidence.d.ts:23
Parameters
Returns
Observable
public window( windowClosingSelector: () => Rx.Observable<TWindowClosing> ) : Observable
Defined in rx.coincidence.d.ts:24
Parameters
windowClosingSelector: () => Rx.Observable<TWindowClosing>
Returns
Observable
public window( windowOpenings: Observable , windowClosingSelector: () => Rx.Observable<TWindowClosing> ) : Observable
Defined in rx.coincidence.d.ts:25
Parameters
windowClosingSelector: () => Rx.Observable<TWindowClosing>
Returns
Observable
public windowWithCount( count: number , skip?: number ) : Observable
Parameters
count: number
skip?: number 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