Methods
public bufferWithCount(count: number, skip?: number): Observable
Parameters
-
count: number
-
skip?: number optional
Returns
Observable
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 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
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 doWhile(condition: () => boolean): Observable
Repeats source as long as condition holds emulating a do while loop.
Parameters
Returns
Observable
An observable sequence which is repeated as long as the condition holds.
public expand(selector: (item: T) => Rx.Observable<T>, scheduler?: IScheduler): Observable
Expands an observable sequence by recursively invoking selector.
Parameters
Returns
Observable
An observable sequence containing all the elements produced by the recursive expansion.
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 forkJoin(second: Observable, resultSelector: (left: T, right: TSecond) => TResult): Observable
Runs two observable sequences in parallel and combines their last elemenets.
Parameters
Returns
Observable
An observable sequence with the result of calling the selector function with the last elements of both input sequences.
public forkJoin(second: IPromise, resultSelector: (left: T, right: TSecond) => TResult): Observable
Parameters
-
-
resultSelector: (left: T, right: TSecond) => TResult
Returns
Observable
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 let(selector: (source: Rx.Observable<T>) => Rx.Observable<TResult>): Observable
Returns an observable sequence that is the result of invoking the selector on the source sequence, without sharing subscriptions.
This operator allows for a fluent style of writing queries that use the same sequence multiple times.
Parameters
Returns
Observable
An observable sequence that contains the elements of a sequence produced by multicasting the source sequence within a selector function.
public letBind(selector: (source: Rx.Observable<T>) => Rx.Observable<TResult>): Observable
Returns an observable sequence that is the result of invoking the selector on the source sequence, without sharing subscriptions.
This operator allows for a fluent style of writing queries that use the same sequence multiple times.
Parameters
Returns
Observable
An observable sequence that contains the elements of a sequence produced by multicasting the source sequence within a selector function.
public manySelect(selector: (item: Rx.Observable<T>, index: number, source: Rx.Observable<T>) => TResult, scheduler?: IScheduler): Observable
Comonadic bind operator.
Parameters
Returns
Observable
An observable sequence which results from the comonadic bind operation.
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>
public repeat(repeatCount?: number): Observable
Parameters
-
repeatCount?: number 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.
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
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 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 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
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