@types/rx-lite

  • Version 4.0.6
  • Published
  • 53.5 kB
  • 2 dependencies
  • MIT license

Install

npm i @types/rx-lite
yarn add @types/rx-lite
pnpm add @types/rx-lite

Overview

TypeScript definitions for rx-lite

Index

Namespaces

namespace Rx

namespace Rx {}

    variable Observable

    const Observable: ObservableStatic;

      variable Observer

      const Observer: ObserverStatic;

        variable Scheduler

        const Scheduler: SchedulerStatic;

          class CompositeDisposable

          class CompositeDisposable implements IDisposable {}

            constructor

            constructor(...disposables: IDisposable[]);

              constructor

              constructor(disposables: IDisposable[]);

                property isDisposed

                isDisposed: boolean;

                  property length

                  length: number;

                    method add

                    add: (item: IDisposable) => void;

                      method dispose

                      dispose: () => void;

                        method remove

                        remove: (item: IDisposable) => boolean;

                          method toArray

                          toArray: () => IDisposable[];

                            class Disposable

                            class Disposable implements IDisposable {}

                              constructor

                              constructor(action: () => void);

                                property empty

                                static empty: IDisposable;

                                  method create

                                  static create: (action: () => void) => IDisposable;

                                    method dispose

                                    dispose: () => void;

                                      class Notification

                                      class Notification<T> {}

                                        property exception

                                        exception: any;

                                          property hasValue

                                          hasValue: boolean;

                                            property kind

                                            kind: string;

                                              property value

                                              value: {};

                                                method accept

                                                accept: {
                                                (observer: IObserver<T>): void;
                                                <TResult>(
                                                onNext: (value: T) => TResult,
                                                onError?: (exception: any) => TResult,
                                                onCompleted?: () => TResult
                                                ): TResult;
                                                };

                                                  method createOnCompleted

                                                  static createOnCompleted: <T>() => Notification<T>;

                                                    method createOnError

                                                    static createOnError: <T>(exception: any) => Notification<T>;

                                                      method createOnNext

                                                      static createOnNext: <T>(value: T) => Notification<T>;

                                                        method equals

                                                        equals: (other: Notification<T>) => boolean;

                                                          method toObservable

                                                          toObservable: (scheduler?: IScheduler) => Observable<T>;

                                                            class RefCountDisposable

                                                            class RefCountDisposable implements IDisposable {}

                                                              constructor

                                                              constructor(disposable: IDisposable);

                                                                property isDisposed

                                                                isDisposed: boolean;

                                                                  method dispose

                                                                  dispose: () => void;

                                                                    method getDisposable

                                                                    getDisposable: () => IDisposable;

                                                                      class SerialDisposable

                                                                      class SerialDisposable extends SingleAssignmentDisposable {}

                                                                        constructor

                                                                        constructor();

                                                                          class SingleAssignmentDisposable

                                                                          class SingleAssignmentDisposable implements IDisposable {}

                                                                            constructor

                                                                            constructor();

                                                                              property current

                                                                              current: IDisposable;

                                                                                property isDisposed

                                                                                isDisposed: boolean;

                                                                                  method dispose

                                                                                  dispose: () => void;

                                                                                    method getDisposable

                                                                                    getDisposable: () => IDisposable;

                                                                                      method setDisposable

                                                                                      setDisposable: (value: IDisposable) => void;

                                                                                        interface ConnectableObservable

                                                                                        interface ConnectableObservable<T> extends Observable<T> {}

                                                                                          method connect

                                                                                          connect: () => Disposable;

                                                                                            interface DOMEventTarget

                                                                                            interface DOMEventTarget {}

                                                                                              method addEventListener

                                                                                              addEventListener: (
                                                                                              type: string,
                                                                                              listener: (e: any) => any,
                                                                                              useCapture: boolean
                                                                                              ) => void;

                                                                                                method removeEventListener

                                                                                                removeEventListener: (
                                                                                                type: string,
                                                                                                listener: (e: any) => any,
                                                                                                useCapture: boolean
                                                                                                ) => void;

                                                                                                  interface ICurrentThreadScheduler

                                                                                                  interface ICurrentThreadScheduler extends IScheduler {}

                                                                                                    method scheduleRequired

                                                                                                    scheduleRequired: () => boolean;

                                                                                                      interface IObservable

                                                                                                      interface IObservable<T> {}

                                                                                                        method subscribe

                                                                                                        subscribe: {
                                                                                                        (observer: Observer<T>): IDisposable;
                                                                                                        (
                                                                                                        onNext?: (value: T) => void,
                                                                                                        onError?: (exception: any) => void,
                                                                                                        onCompleted?: () => void
                                                                                                        ): IDisposable;
                                                                                                        };

                                                                                                          method subscribeOnCompleted

                                                                                                          subscribeOnCompleted: (onCompleted: () => void, thisArg?: any) => IDisposable;

                                                                                                            method subscribeOnError

                                                                                                            subscribeOnError: (
                                                                                                            onError: (exception: any) => void,
                                                                                                            thisArg?: any
                                                                                                            ) => IDisposable;

                                                                                                              method subscribeOnNext

                                                                                                              subscribeOnNext: (onNext: (value: T) => void, thisArg?: any) => IDisposable;

                                                                                                                interface IObserver

                                                                                                                interface IObserver<T> {}

                                                                                                                  method onCompleted

                                                                                                                  onCompleted: () => void;

                                                                                                                    method onError

                                                                                                                    onError: (exception: any) => void;

                                                                                                                      method onNext

                                                                                                                      onNext: (value: T) => void;

                                                                                                                        interface IScheduler

                                                                                                                        interface IScheduler {}

                                                                                                                          method isScheduler

                                                                                                                          isScheduler: (value: any) => boolean;

                                                                                                                            method now

                                                                                                                            now: () => number;

                                                                                                                              method schedule

                                                                                                                              schedule: (action: () => void) => IDisposable;

                                                                                                                                method schedulePeriodic

                                                                                                                                schedulePeriodic: (period: number, action: () => void) => IDisposable;

                                                                                                                                  method schedulePeriodicWithState

                                                                                                                                  schedulePeriodicWithState: <TState>(
                                                                                                                                  state: TState,
                                                                                                                                  period: number,
                                                                                                                                  action: (state: TState) => TState
                                                                                                                                  ) => IDisposable;

                                                                                                                                    method scheduleRecursive

                                                                                                                                    scheduleRecursive: (action: (action: () => void) => void) => IDisposable;

                                                                                                                                      method scheduleRecursiveWithAbsolute

                                                                                                                                      scheduleRecursiveWithAbsolute: (
                                                                                                                                      dueTime: number,
                                                                                                                                      action: (action: (dueTime: number) => void) => void
                                                                                                                                      ) => IDisposable;

                                                                                                                                        method scheduleRecursiveWithAbsoluteAndState

                                                                                                                                        scheduleRecursiveWithAbsoluteAndState: <TState>(
                                                                                                                                        state: TState,
                                                                                                                                        dueTime: number,
                                                                                                                                        action: (
                                                                                                                                        state: TState,
                                                                                                                                        action: (state: TState, dueTime: number) => void
                                                                                                                                        ) => void
                                                                                                                                        ) => IDisposable;

                                                                                                                                          method scheduleRecursiveWithRelative

                                                                                                                                          scheduleRecursiveWithRelative: (
                                                                                                                                          dueTime: number,
                                                                                                                                          action: (action: (dueTime: number) => void) => void
                                                                                                                                          ) => IDisposable;

                                                                                                                                            method scheduleRecursiveWithRelativeAndState

                                                                                                                                            scheduleRecursiveWithRelativeAndState: <TState>(
                                                                                                                                            state: TState,
                                                                                                                                            dueTime: number,
                                                                                                                                            action: (
                                                                                                                                            state: TState,
                                                                                                                                            action: (state: TState, dueTime: number) => void
                                                                                                                                            ) => void
                                                                                                                                            ) => IDisposable;

                                                                                                                                              method scheduleRecursiveWithState

                                                                                                                                              scheduleRecursiveWithState: <TState>(
                                                                                                                                              state: TState,
                                                                                                                                              action: (state: TState, action: (state: TState) => void) => void
                                                                                                                                              ) => IDisposable;

                                                                                                                                                method scheduleWithAbsolute

                                                                                                                                                scheduleWithAbsolute: (dueTime: number, action: () => void) => IDisposable;

                                                                                                                                                  method scheduleWithAbsoluteAndState

                                                                                                                                                  scheduleWithAbsoluteAndState: <TState>(
                                                                                                                                                  state: TState,
                                                                                                                                                  dueTime: number,
                                                                                                                                                  action: (scheduler: IScheduler, state: TState) => IDisposable
                                                                                                                                                  ) => IDisposable;

                                                                                                                                                    method scheduleWithRelative

                                                                                                                                                    scheduleWithRelative: (dueTime: number, action: () => void) => IDisposable;

                                                                                                                                                      method scheduleWithRelativeAndState

                                                                                                                                                      scheduleWithRelativeAndState: <TState>(
                                                                                                                                                      state: TState,
                                                                                                                                                      dueTime: number,
                                                                                                                                                      action: (scheduler: IScheduler, state: TState) => IDisposable
                                                                                                                                                      ) => IDisposable;

                                                                                                                                                        method scheduleWithState

                                                                                                                                                        scheduleWithState: <TState>(
                                                                                                                                                        state: TState,
                                                                                                                                                        action: (scheduler: IScheduler, state: TState) => IDisposable
                                                                                                                                                        ) => IDisposable;

                                                                                                                                                          interface NativeEventTarget

                                                                                                                                                          interface NativeEventTarget {}

                                                                                                                                                            method off

                                                                                                                                                            off: (name: string, cb: (e: any) => any) => void;

                                                                                                                                                              method on

                                                                                                                                                              on: (name: string, cb: (e: any) => any) => void;

                                                                                                                                                                interface NodeEventTarget

                                                                                                                                                                interface NodeEventTarget {}

                                                                                                                                                                  method addListener

                                                                                                                                                                  addListener: (name: string, cb: (e: any) => any) => void;

                                                                                                                                                                    interface Observable

                                                                                                                                                                    interface Observable<T> extends IObservable<T> {}

                                                                                                                                                                      method asObservable

                                                                                                                                                                      asObservable: () => Observable<T>;

                                                                                                                                                                        method catch

                                                                                                                                                                        catch: {
                                                                                                                                                                        (handler: (exception: Error) => IPromise<T> | Observable<T>): Observable<T>;
                                                                                                                                                                        (second: Observable<T>): Observable<T>;
                                                                                                                                                                        };

                                                                                                                                                                          method catchException

                                                                                                                                                                          catchException: {
                                                                                                                                                                          (handler: (exception: Error) => IPromise<T> | Observable<T>): Observable<T>;
                                                                                                                                                                          (second: Observable<T>): Observable<T>;
                                                                                                                                                                          };

                                                                                                                                                                            method combineLatest

                                                                                                                                                                            combineLatest: {
                                                                                                                                                                            <T2>(second: Observable<T2> | IPromise<T2>): Observable<[T, T2]>;
                                                                                                                                                                            <T2, TResult>(
                                                                                                                                                                            second: any,
                                                                                                                                                                            resultSelector: (v1: T, v2: T2) => TResult
                                                                                                                                                                            ): Observable<TResult>;
                                                                                                                                                                            <T2, T3>(second: any, third: any): Observable<[T, T2, T3]>;
                                                                                                                                                                            <T2, T3, TResult>(
                                                                                                                                                                            second: any,
                                                                                                                                                                            third: any,
                                                                                                                                                                            resultSelector: (v1: T, v2: T2, v3: T3) => TResult
                                                                                                                                                                            ): Observable<TResult>;
                                                                                                                                                                            <T2, T3, T4>(second: any, third: any, fourth: any): Observable<
                                                                                                                                                                            [T, T2, T3, T4]
                                                                                                                                                                            >;
                                                                                                                                                                            <T2, T3, T4, TResult>(
                                                                                                                                                                            second: any,
                                                                                                                                                                            third: any,
                                                                                                                                                                            fourth: any,
                                                                                                                                                                            resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
                                                                                                                                                                            ): Observable<TResult>;
                                                                                                                                                                            <T2, T3, T4, T5>(
                                                                                                                                                                            second: any,
                                                                                                                                                                            third: any,
                                                                                                                                                                            fourth: any,
                                                                                                                                                                            fifth: any
                                                                                                                                                                            ): Observable<[T, T2, T3, T4, T5]>;
                                                                                                                                                                            <T2, T3, T4, T5, TResult>(
                                                                                                                                                                            second: any,
                                                                                                                                                                            third: any,
                                                                                                                                                                            fourth: any,
                                                                                                                                                                            fifth: any,
                                                                                                                                                                            resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult
                                                                                                                                                                            ): Observable<TResult>;
                                                                                                                                                                            <TOther, TResult>(
                                                                                                                                                                            souces: any[],
                                                                                                                                                                            resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult
                                                                                                                                                                            ): Observable<TResult>;
                                                                                                                                                                            };

                                                                                                                                                                              method concat

                                                                                                                                                                              concat: {
                                                                                                                                                                              (...sources: (Observable<T> | IPromise<T>)[]): Observable<T>;
                                                                                                                                                                              (sources: any[]): Observable<T>;
                                                                                                                                                                              };

                                                                                                                                                                                method concatAll

                                                                                                                                                                                concatAll: () => T;

                                                                                                                                                                                  method concatMap

                                                                                                                                                                                  concatMap: {
                                                                                                                                                                                  <T2, R>(
                                                                                                                                                                                  selector: (value: T, index: number) => Observable<T2>,
                                                                                                                                                                                  resultSelector: (value1: T, value2: T2, index: number) => R
                                                                                                                                                                                  ): Observable<R>;
                                                                                                                                                                                  <T2, R>(
                                                                                                                                                                                  selector: (value: T, index: number) => IPromise<T2>,
                                                                                                                                                                                  resultSelector: (value1: T, value2: T2, index: number) => R
                                                                                                                                                                                  ): Observable<R>;
                                                                                                                                                                                  <R>(selector: (value: T, index: number) => Observable<R>): Observable<R>;
                                                                                                                                                                                  <R>(selector: (value: T, index: number) => IPromise<R>): Observable<R>;
                                                                                                                                                                                  <R>(selector: (value: T, index: number) => R[]): Observable<R>;
                                                                                                                                                                                  <R>(sequence: Observable<R>): Observable<R>;
                                                                                                                                                                                  <R>(sequence: R[]): Observable<R>;
                                                                                                                                                                                  };

                                                                                                                                                                                    method concatObservable

                                                                                                                                                                                    concatObservable: () => Observable<T>;

                                                                                                                                                                                      method dematerialize

                                                                                                                                                                                      dematerialize: <TOrigin>() => Observable<TOrigin>;

                                                                                                                                                                                        method distinctUntilChanged

                                                                                                                                                                                        distinctUntilChanged: {
                                                                                                                                                                                        (skipParameter: boolean, comparer: (x: T, y: T) => boolean): Observable<T>;
                                                                                                                                                                                        <TValue>(
                                                                                                                                                                                        keySelector?: (value: T) => TValue,
                                                                                                                                                                                        comparer?: (x: TValue, y: TValue) => boolean
                                                                                                                                                                                        ): Observable<T>;
                                                                                                                                                                                        };

                                                                                                                                                                                          method do

                                                                                                                                                                                          do: {
                                                                                                                                                                                          (observer: Observer<T>): Observable<T>;
                                                                                                                                                                                          (
                                                                                                                                                                                          onNext?: (value: T) => void,
                                                                                                                                                                                          onError?: (exception: Error) => void,
                                                                                                                                                                                          onCompleted?: () => void
                                                                                                                                                                                          ): Observable<T>;
                                                                                                                                                                                          };

                                                                                                                                                                                            method doAction

                                                                                                                                                                                            doAction: {
                                                                                                                                                                                            (observer: Observer<T>): Observable<T>;
                                                                                                                                                                                            (
                                                                                                                                                                                            onNext?: (value: T) => void,
                                                                                                                                                                                            onError?: (exception: Error) => void,
                                                                                                                                                                                            onCompleted?: () => void
                                                                                                                                                                                            ): Observable<T>;
                                                                                                                                                                                            };

                                                                                                                                                                                              method doOnCompleted

                                                                                                                                                                                              doOnCompleted: (onCompleted: () => void, thisArg?: any) => Observable<T>;

                                                                                                                                                                                                method doOnError

                                                                                                                                                                                                doOnError: (onError: (exception: any) => void, thisArg?: any) => Observable<T>;

                                                                                                                                                                                                  method doOnNext

                                                                                                                                                                                                  doOnNext: (onNext: (value: T) => void, thisArg?: any) => Observable<T>;

                                                                                                                                                                                                    method exclusive

                                                                                                                                                                                                    exclusive: <R>() => Observable<R>;
                                                                                                                                                                                                    • Performs a exclusive waiting for the first to finish before subscribing to another observable. Observables that come in between subscriptions will be dropped on the floor. Can be applied on Observable<Observable<R>> or Observable<IPromise<R>>. 2.2.28

                                                                                                                                                                                                      Returns

                                                                                                                                                                                                      A exclusive observable with only the results that happen when subscribed.

                                                                                                                                                                                                    method exclusiveMap

                                                                                                                                                                                                    exclusiveMap: <I, R>(
                                                                                                                                                                                                    selector: (value: I, index: number, source: Observable<I>) => R,
                                                                                                                                                                                                    thisArg?: any
                                                                                                                                                                                                    ) => Observable<R>;
                                                                                                                                                                                                    • Performs a exclusive map waiting for the first to finish before subscribing to another observable. Observables that come in between subscriptions will be dropped on the floor. Can be applied on Observable<Observable<I>> or Observable<IPromise<I>>. 2.2.28

                                                                                                                                                                                                      Parameter selector

                                                                                                                                                                                                      Selector to invoke for every item in the current subscription.

                                                                                                                                                                                                      Parameter thisArg

                                                                                                                                                                                                      An optional context to invoke with the selector parameter.

                                                                                                                                                                                                      Returns

                                                                                                                                                                                                      An exclusive observable with only the results that happen when subscribed.

                                                                                                                                                                                                    method filter

                                                                                                                                                                                                    filter: (
                                                                                                                                                                                                    predicate: (value: T, index: number, source: Observable<T>) => boolean,
                                                                                                                                                                                                    thisArg?: any
                                                                                                                                                                                                    ) => Observable<T>;

                                                                                                                                                                                                      method finally

                                                                                                                                                                                                      finally: (action: () => void) => Observable<T>;

                                                                                                                                                                                                        method finallyAction

                                                                                                                                                                                                        finallyAction: (action: () => void) => Observable<T>;

                                                                                                                                                                                                          method flatMap

                                                                                                                                                                                                          flatMap: {
                                                                                                                                                                                                          <TOther, TResult>(
                                                                                                                                                                                                          selector: (value: T) => Observable<TOther>,
                                                                                                                                                                                                          resultSelector: (item: T, other: TOther) => TResult
                                                                                                                                                                                                          ): Observable<TResult>;
                                                                                                                                                                                                          <TOther, TResult>(
                                                                                                                                                                                                          selector: (value: T) => IPromise<TOther>,
                                                                                                                                                                                                          resultSelector: (item: T, other: TOther) => TResult
                                                                                                                                                                                                          ): Observable<TResult>;
                                                                                                                                                                                                          <TResult>(selector: (value: T) => Observable<TResult>): Observable<TResult>;
                                                                                                                                                                                                          <TResult>(selector: (value: T) => IPromise<TResult>): Observable<TResult>;
                                                                                                                                                                                                          <TResult>(other: Observable<TResult>): Observable<TResult>;
                                                                                                                                                                                                          <TResult>(other: IPromise<TResult>): Observable<TResult>;
                                                                                                                                                                                                          <TResult>(selector: (value: T) => TResult[]): Observable<TResult>;
                                                                                                                                                                                                          };

                                                                                                                                                                                                            method flatMapLatest

                                                                                                                                                                                                            flatMapLatest: <TResult>(
                                                                                                                                                                                                            selector: (
                                                                                                                                                                                                            value: T,
                                                                                                                                                                                                            index: number,
                                                                                                                                                                                                            source: Observable<T>
                                                                                                                                                                                                            ) => Observable<TResult>,
                                                                                                                                                                                                            thisArg?: any
                                                                                                                                                                                                            ) => Observable<TResult>;
                                                                                                                                                                                                            • 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.

                                                                                                                                                                                                              Parameter selector

                                                                                                                                                                                                              A transform function to apply to each source element; the second parameter of the function represents the index of the source element.

                                                                                                                                                                                                              Parameter thisArg

                                                                                                                                                                                                              Object to use as this when executing callback.

                                                                                                                                                                                                              Returns

                                                                                                                                                                                                              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.

                                                                                                                                                                                                            method flatMapObserver

                                                                                                                                                                                                            flatMapObserver: <T2, T3, T4>(
                                                                                                                                                                                                            onNext: (value: T, index: number) => Observable<T2>,
                                                                                                                                                                                                            onError: (exception: any) => Observable<T3>,
                                                                                                                                                                                                            onCompleted: () => Observable<T4>,
                                                                                                                                                                                                            thisArg?: any
                                                                                                                                                                                                            ) => Observable<T2 | T3 | T4>;
                                                                                                                                                                                                            • Projects each notification of an observable sequence to an observable sequence and merges the resulting observable sequences into one observable sequence.

                                                                                                                                                                                                              Parameter onNext

                                                                                                                                                                                                              A transform function to apply to each element; the second parameter of the function represents the index of the source element.

                                                                                                                                                                                                              Parameter onError

                                                                                                                                                                                                              A transform function to apply when an error occurs in the source sequence.

                                                                                                                                                                                                              Parameter onCompleted

                                                                                                                                                                                                              A transform function to apply when the end of the source sequence is reached.

                                                                                                                                                                                                              Parameter thisArg

                                                                                                                                                                                                              An optional "this" to use to invoke each transform.

                                                                                                                                                                                                              Returns

                                                                                                                                                                                                              An observable sequence whose elements are the result of invoking the one-to-many transform function corresponding to each notification in the input sequence.

                                                                                                                                                                                                            method forEach

                                                                                                                                                                                                            forEach: (
                                                                                                                                                                                                            onNext?: (value: T) => void,
                                                                                                                                                                                                            onError?: (exception: any) => void,
                                                                                                                                                                                                            onCompleted?: () => void
                                                                                                                                                                                                            ) => IDisposable;

                                                                                                                                                                                                              method ignoreElements

                                                                                                                                                                                                              ignoreElements: () => Observable<T>;

                                                                                                                                                                                                                method map

                                                                                                                                                                                                                map: <TResult>(
                                                                                                                                                                                                                selector: (value: T, index: number, source: Observable<T>) => TResult,
                                                                                                                                                                                                                thisArg?: any
                                                                                                                                                                                                                ) => Observable<TResult>;

                                                                                                                                                                                                                  method materialize

                                                                                                                                                                                                                  materialize: () => Observable<Notification<T>>;

                                                                                                                                                                                                                    method merge

                                                                                                                                                                                                                    merge: {
                                                                                                                                                                                                                    (maxConcurrent: number): T;
                                                                                                                                                                                                                    (other: Observable<T>): Observable<T>;
                                                                                                                                                                                                                    (other: IPromise<T>): Observable<T>;
                                                                                                                                                                                                                    };

                                                                                                                                                                                                                      method mergeAll

                                                                                                                                                                                                                      mergeAll: () => T;

                                                                                                                                                                                                                        method mergeObservable

                                                                                                                                                                                                                        mergeObservable: () => T;

                                                                                                                                                                                                                          method pluck

                                                                                                                                                                                                                          pluck: <TResult>(prop: string) => Observable<TResult>;

                                                                                                                                                                                                                            method publish

                                                                                                                                                                                                                            publish: () => ConnectableObservable<T>;

                                                                                                                                                                                                                              method repeat

                                                                                                                                                                                                                              repeat: (repeatCount?: number) => Observable<T>;

                                                                                                                                                                                                                                method retry

                                                                                                                                                                                                                                retry: (retryCount?: number) => Observable<T>;

                                                                                                                                                                                                                                  method retryWhen

                                                                                                                                                                                                                                  retryWhen: <TError>(
                                                                                                                                                                                                                                  notifier: (errors: Observable<TError>) => Observable<any>
                                                                                                                                                                                                                                  ) => Observable<T>;

                                                                                                                                                                                                                                    method scan

                                                                                                                                                                                                                                    scan: {
                                                                                                                                                                                                                                    <TAcc>(
                                                                                                                                                                                                                                    accumulator: (
                                                                                                                                                                                                                                    acc: TAcc,
                                                                                                                                                                                                                                    value: T,
                                                                                                                                                                                                                                    index?: number,
                                                                                                                                                                                                                                    source?: Observable<TAcc>
                                                                                                                                                                                                                                    ) => TAcc,
                                                                                                                                                                                                                                    seed: TAcc
                                                                                                                                                                                                                                    ): Observable<TAcc>;
                                                                                                                                                                                                                                    (
                                                                                                                                                                                                                                    accumulator: (
                                                                                                                                                                                                                                    acc: T,
                                                                                                                                                                                                                                    value: T,
                                                                                                                                                                                                                                    index?: number,
                                                                                                                                                                                                                                    source?: Observable<T>
                                                                                                                                                                                                                                    ) => T
                                                                                                                                                                                                                                    ): Observable<T>;
                                                                                                                                                                                                                                    };
                                                                                                                                                                                                                                    • Applies an accumulator function over an observable sequence and returns each intermediate result. The optional seed value is used as the initial accumulator value. For aggregation behavior with no intermediate results, see Observable.aggregate.

                                                                                                                                                                                                                                      Parameter accumulator

                                                                                                                                                                                                                                      An accumulator function to be invoked on each element.

                                                                                                                                                                                                                                      Parameter seed

                                                                                                                                                                                                                                      The initial accumulator value.

                                                                                                                                                                                                                                      Returns

                                                                                                                                                                                                                                      An observable sequence containing the accumulated values.

                                                                                                                                                                                                                                      Example 1

                                                                                                                                                                                                                                      var res = source.scan(function (acc, x) { return acc + x; }); var res = source.scan(function (acc, x) { return acc + x; }, 0);

                                                                                                                                                                                                                                    method select

                                                                                                                                                                                                                                    select: <TResult>(
                                                                                                                                                                                                                                    selector: (value: T, index: number, source: Observable<T>) => TResult,
                                                                                                                                                                                                                                    thisArg?: any
                                                                                                                                                                                                                                    ) => Observable<TResult>;

                                                                                                                                                                                                                                      method selectConcat

                                                                                                                                                                                                                                      selectConcat: {
                                                                                                                                                                                                                                      <T2, R>(
                                                                                                                                                                                                                                      selector: (value: T, index: number) => Observable<T2>,
                                                                                                                                                                                                                                      resultSelector: (value1: T, value2: T2, index: number) => R
                                                                                                                                                                                                                                      ): Observable<R>;
                                                                                                                                                                                                                                      <T2, R>(
                                                                                                                                                                                                                                      selector: (value: T, index: number) => IPromise<T2>,
                                                                                                                                                                                                                                      resultSelector: (value1: T, value2: T2, index: number) => R
                                                                                                                                                                                                                                      ): Observable<R>;
                                                                                                                                                                                                                                      <R>(selector: (value: T, index: number) => Observable<R>): Observable<R>;
                                                                                                                                                                                                                                      <R>(selector: (value: T, index: number) => IPromise<R>): Observable<R>;
                                                                                                                                                                                                                                      <R>(sequence: Observable<R>): Observable<R>;
                                                                                                                                                                                                                                      };

                                                                                                                                                                                                                                        method selectMany

                                                                                                                                                                                                                                        selectMany: {
                                                                                                                                                                                                                                        <TOther, TResult>(
                                                                                                                                                                                                                                        selector: (value: T) => Observable<TOther>,
                                                                                                                                                                                                                                        resultSelector: (item: T, other: TOther) => TResult
                                                                                                                                                                                                                                        ): Observable<TResult>;
                                                                                                                                                                                                                                        <TOther, TResult>(
                                                                                                                                                                                                                                        selector: (value: T) => IPromise<TOther>,
                                                                                                                                                                                                                                        resultSelector: (item: T, other: TOther) => TResult
                                                                                                                                                                                                                                        ): Observable<TResult>;
                                                                                                                                                                                                                                        <TResult>(selector: (value: T) => Observable<TResult>): Observable<TResult>;
                                                                                                                                                                                                                                        <TResult>(selector: (value: T) => IPromise<TResult>): Observable<TResult>;
                                                                                                                                                                                                                                        <TResult>(other: Observable<TResult>): Observable<TResult>;
                                                                                                                                                                                                                                        <TResult>(other: IPromise<TResult>): Observable<TResult>;
                                                                                                                                                                                                                                        <TResult>(selector: (value: T) => TResult[]): Observable<TResult>;
                                                                                                                                                                                                                                        };

                                                                                                                                                                                                                                          method selectManyObserver

                                                                                                                                                                                                                                          selectManyObserver: <T2, T3, T4>(
                                                                                                                                                                                                                                          onNext: (value: T, index: number) => Observable<T2>,
                                                                                                                                                                                                                                          onError: (exception: any) => Observable<T3>,
                                                                                                                                                                                                                                          onCompleted: () => Observable<T4>,
                                                                                                                                                                                                                                          thisArg?: any
                                                                                                                                                                                                                                          ) => Observable<T2 | T3 | T4>;
                                                                                                                                                                                                                                          • Projects each notification of an observable sequence to an observable sequence and merges the resulting observable sequences into one observable sequence.

                                                                                                                                                                                                                                            Parameter onNext

                                                                                                                                                                                                                                            A transform function to apply to each element; the second parameter of the function represents the index of the source element.

                                                                                                                                                                                                                                            Parameter onError

                                                                                                                                                                                                                                            A transform function to apply when an error occurs in the source sequence.

                                                                                                                                                                                                                                            Parameter onCompleted

                                                                                                                                                                                                                                            A transform function to apply when the end of the source sequence is reached.

                                                                                                                                                                                                                                            Parameter thisArg

                                                                                                                                                                                                                                            An optional "this" to use to invoke each transform.

                                                                                                                                                                                                                                            Returns

                                                                                                                                                                                                                                            An observable sequence whose elements are the result of invoking the one-to-many transform function corresponding to each notification in the input sequence.

                                                                                                                                                                                                                                          method selectSwitch

                                                                                                                                                                                                                                          selectSwitch: <TResult>(
                                                                                                                                                                                                                                          selector: (
                                                                                                                                                                                                                                          value: T,
                                                                                                                                                                                                                                          index: number,
                                                                                                                                                                                                                                          source: Observable<T>
                                                                                                                                                                                                                                          ) => Observable<TResult>,
                                                                                                                                                                                                                                          thisArg?: any
                                                                                                                                                                                                                                          ) => Observable<TResult>;
                                                                                                                                                                                                                                          • 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.

                                                                                                                                                                                                                                            Parameter selector

                                                                                                                                                                                                                                            A transform function to apply to each source element; the second parameter of the function represents the index of the source element.

                                                                                                                                                                                                                                            Parameter thisArg

                                                                                                                                                                                                                                            Object to use as this when executing callback.

                                                                                                                                                                                                                                            Returns

                                                                                                                                                                                                                                            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.

                                                                                                                                                                                                                                          method skip

                                                                                                                                                                                                                                          skip: (count: number) => Observable<T>;

                                                                                                                                                                                                                                            method skipLast

                                                                                                                                                                                                                                            skipLast: (count: number) => Observable<T>;

                                                                                                                                                                                                                                              method skipUntil

                                                                                                                                                                                                                                              skipUntil: {
                                                                                                                                                                                                                                              <T2>(other: Observable<T2>): Observable<T>;
                                                                                                                                                                                                                                              <T2>(other: IPromise<T2>): Observable<T>;
                                                                                                                                                                                                                                              };

                                                                                                                                                                                                                                                method skipWhile

                                                                                                                                                                                                                                                skipWhile: (
                                                                                                                                                                                                                                                predicate: (value: T, index: number, source: Observable<T>) => boolean,
                                                                                                                                                                                                                                                thisArg?: any
                                                                                                                                                                                                                                                ) => Observable<T>;

                                                                                                                                                                                                                                                  method startWith

                                                                                                                                                                                                                                                  startWith: {
                                                                                                                                                                                                                                                  (...values: T[]): Observable<T>;
                                                                                                                                                                                                                                                  (scheduler: IScheduler, ...values: T[]): Observable<T>;
                                                                                                                                                                                                                                                  };

                                                                                                                                                                                                                                                    method switch

                                                                                                                                                                                                                                                    switch: () => T;

                                                                                                                                                                                                                                                      method switchLatest

                                                                                                                                                                                                                                                      switchLatest: () => T;

                                                                                                                                                                                                                                                        method switchMap

                                                                                                                                                                                                                                                        switchMap: <TResult>(
                                                                                                                                                                                                                                                        selector: (value: T, index: number, source: Observable<T>) => TResult,
                                                                                                                                                                                                                                                        thisArg?: any
                                                                                                                                                                                                                                                        ) => Observable<TResult>;
                                                                                                                                                                                                                                                        • 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.

                                                                                                                                                                                                                                                          Parameter selector

                                                                                                                                                                                                                                                          A transform function to apply to each source element; the second parameter of the function represents the index of the source element.

                                                                                                                                                                                                                                                          Parameter thisArg

                                                                                                                                                                                                                                                          Object to use as this when executing callback. 2.2.28

                                                                                                                                                                                                                                                          Returns

                                                                                                                                                                                                                                                          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.

                                                                                                                                                                                                                                                        method take

                                                                                                                                                                                                                                                        take: (count: number, scheduler?: IScheduler) => Observable<T>;

                                                                                                                                                                                                                                                          method takeLast

                                                                                                                                                                                                                                                          takeLast: (count: number) => Observable<T>;

                                                                                                                                                                                                                                                            method takeLastBuffer

                                                                                                                                                                                                                                                            takeLastBuffer: (count: number) => Observable<T[]>;

                                                                                                                                                                                                                                                              method takeUntil

                                                                                                                                                                                                                                                              takeUntil: {
                                                                                                                                                                                                                                                              <T2>(other: Observable<T2>): Observable<T>;
                                                                                                                                                                                                                                                              <T2>(other: IPromise<T2>): Observable<T>;
                                                                                                                                                                                                                                                              };

                                                                                                                                                                                                                                                                method takeWhile

                                                                                                                                                                                                                                                                takeWhile: (
                                                                                                                                                                                                                                                                predicate: (value: T, index: number, source: Observable<T>) => boolean,
                                                                                                                                                                                                                                                                thisArg?: any
                                                                                                                                                                                                                                                                ) => Observable<T>;

                                                                                                                                                                                                                                                                  method tap

                                                                                                                                                                                                                                                                  tap: {
                                                                                                                                                                                                                                                                  (observer: Observer<T>): Observable<T>;
                                                                                                                                                                                                                                                                  (
                                                                                                                                                                                                                                                                  onNext?: (value: T) => void,
                                                                                                                                                                                                                                                                  onError?: (exception: Error) => void,
                                                                                                                                                                                                                                                                  onCompleted?: () => void
                                                                                                                                                                                                                                                                  ): Observable<T>;
                                                                                                                                                                                                                                                                  };

                                                                                                                                                                                                                                                                    method tapOnCompleted

                                                                                                                                                                                                                                                                    tapOnCompleted: (onCompleted: () => void, thisArg?: any) => Observable<T>;

                                                                                                                                                                                                                                                                      method tapOnError

                                                                                                                                                                                                                                                                      tapOnError: (onError: (exception: any) => void, thisArg?: any) => Observable<T>;

                                                                                                                                                                                                                                                                        method tapOnNext

                                                                                                                                                                                                                                                                        tapOnNext: (onNext: (value: T) => void, thisArg?: any) => Observable<T>;

                                                                                                                                                                                                                                                                          method toArray

                                                                                                                                                                                                                                                                          toArray: () => Observable<T[]>;

                                                                                                                                                                                                                                                                            method toPromise

                                                                                                                                                                                                                                                                            toPromise: {
                                                                                                                                                                                                                                                                            <TPromise extends IPromise<T>>(
                                                                                                                                                                                                                                                                            promiseCtor: new (
                                                                                                                                                                                                                                                                            resolver: (
                                                                                                                                                                                                                                                                            resolvePromise: (value: T) => void,
                                                                                                                                                                                                                                                                            rejectPromise: (reason: any) => void
                                                                                                                                                                                                                                                                            ) => void
                                                                                                                                                                                                                                                                            ) => TPromise
                                                                                                                                                                                                                                                                            ): TPromise;
                                                                                                                                                                                                                                                                            (
                                                                                                                                                                                                                                                                            promiseCtor?: new (
                                                                                                                                                                                                                                                                            resolver: (
                                                                                                                                                                                                                                                                            resolvePromise: (value: T) => void,
                                                                                                                                                                                                                                                                            rejectPromise: (reason: any) => void
                                                                                                                                                                                                                                                                            ) => void
                                                                                                                                                                                                                                                                            ) => IPromise<T>
                                                                                                                                                                                                                                                                            ): IPromise<T>;
                                                                                                                                                                                                                                                                            };
                                                                                                                                                                                                                                                                            • Converts an existing observable sequence to an ES6 Compatible Promise

                                                                                                                                                                                                                                                                              Parameter promiseCtor

                                                                                                                                                                                                                                                                              The constructor of the promise.

                                                                                                                                                                                                                                                                              Returns

                                                                                                                                                                                                                                                                              An ES6 compatible promise with the last value from the observable sequence.

                                                                                                                                                                                                                                                                              Example 1

                                                                                                                                                                                                                                                                              var promise = Rx.Observable.return(42).toPromise(RSVP.Promise);

                                                                                                                                                                                                                                                                            • Converts an existing observable sequence to an ES6 Compatible Promise

                                                                                                                                                                                                                                                                              Parameter promiseCtor

                                                                                                                                                                                                                                                                              The constructor of the promise. If not provided, it looks for it in Rx.config.Promise.

                                                                                                                                                                                                                                                                              Returns

                                                                                                                                                                                                                                                                              An ES6 compatible promise with the last value from the observable sequence.

                                                                                                                                                                                                                                                                              Example 1

                                                                                                                                                                                                                                                                              var promise = Rx.Observable.return(42).toPromise(RSVP.Promise);

                                                                                                                                                                                                                                                                              // With config Rx.config.Promise = RSVP.Promise; var promise = Rx.Observable.return(42).toPromise();

                                                                                                                                                                                                                                                                            method where

                                                                                                                                                                                                                                                                            where: (
                                                                                                                                                                                                                                                                            predicate: (value: T, index: number, source: Observable<T>) => boolean,
                                                                                                                                                                                                                                                                            thisArg?: any
                                                                                                                                                                                                                                                                            ) => Observable<T>;

                                                                                                                                                                                                                                                                              method withLatestFrom

                                                                                                                                                                                                                                                                              withLatestFrom: {
                                                                                                                                                                                                                                                                              <T2>(second: Observable<T2> | IPromise<T2>): Observable<[T, T2]>;
                                                                                                                                                                                                                                                                              <T2, TResult>(
                                                                                                                                                                                                                                                                              second: any,
                                                                                                                                                                                                                                                                              resultSelector: (v1: T, v2: T2) => TResult
                                                                                                                                                                                                                                                                              ): Observable<TResult>;
                                                                                                                                                                                                                                                                              <T2, T3>(second: any, third: any): Observable<[T, T2, T3]>;
                                                                                                                                                                                                                                                                              <T2, T3, TResult>(
                                                                                                                                                                                                                                                                              second: any,
                                                                                                                                                                                                                                                                              third: any,
                                                                                                                                                                                                                                                                              resultSelector: (v1: T, v2: T2, v3: T3) => TResult
                                                                                                                                                                                                                                                                              ): Observable<TResult>;
                                                                                                                                                                                                                                                                              <T2, T3, T4>(second: any, third: any, fourth: any): Observable<
                                                                                                                                                                                                                                                                              [T, T2, T3, T4]
                                                                                                                                                                                                                                                                              >;
                                                                                                                                                                                                                                                                              <T2, T3, T4, TResult>(
                                                                                                                                                                                                                                                                              second: any,
                                                                                                                                                                                                                                                                              third: any,
                                                                                                                                                                                                                                                                              fourth: any,
                                                                                                                                                                                                                                                                              resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
                                                                                                                                                                                                                                                                              ): Observable<TResult>;
                                                                                                                                                                                                                                                                              <T2, T3, T4, T5>(
                                                                                                                                                                                                                                                                              second: any,
                                                                                                                                                                                                                                                                              third: any,
                                                                                                                                                                                                                                                                              fourth: any,
                                                                                                                                                                                                                                                                              fifth: any
                                                                                                                                                                                                                                                                              ): Observable<[T, T2, T3, T4, T5]>;
                                                                                                                                                                                                                                                                              <T2, T3, T4, T5, TResult>(
                                                                                                                                                                                                                                                                              second: any,
                                                                                                                                                                                                                                                                              third: any,
                                                                                                                                                                                                                                                                              fourth: any,
                                                                                                                                                                                                                                                                              fifth: any,
                                                                                                                                                                                                                                                                              resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult
                                                                                                                                                                                                                                                                              ): Observable<TResult>;
                                                                                                                                                                                                                                                                              <TOther, TResult>(
                                                                                                                                                                                                                                                                              souces: any[],
                                                                                                                                                                                                                                                                              resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult
                                                                                                                                                                                                                                                                              ): Observable<TResult>;
                                                                                                                                                                                                                                                                              };

                                                                                                                                                                                                                                                                                method zip

                                                                                                                                                                                                                                                                                zip: {
                                                                                                                                                                                                                                                                                <T2>(second: Observable<T2> | IPromise<T2>): Observable<[T, T2]>;
                                                                                                                                                                                                                                                                                <T2, TResult>(
                                                                                                                                                                                                                                                                                second: any,
                                                                                                                                                                                                                                                                                resultSelector: (v1: T, v2: T2) => TResult
                                                                                                                                                                                                                                                                                ): Observable<TResult>;
                                                                                                                                                                                                                                                                                <T2, T3>(second: any, third: any): Observable<[T, T2, T3]>;
                                                                                                                                                                                                                                                                                <T2, T3, TResult>(
                                                                                                                                                                                                                                                                                second: any,
                                                                                                                                                                                                                                                                                third: any,
                                                                                                                                                                                                                                                                                resultSelector: (v1: T, v2: T2, v3: T3) => TResult
                                                                                                                                                                                                                                                                                ): Observable<TResult>;
                                                                                                                                                                                                                                                                                <T2, T3, T4>(second: any, third: any, fourth: any): Observable<
                                                                                                                                                                                                                                                                                [T, T2, T3, T4]
                                                                                                                                                                                                                                                                                >;
                                                                                                                                                                                                                                                                                <T2, T3, T4, TResult>(
                                                                                                                                                                                                                                                                                second: any,
                                                                                                                                                                                                                                                                                third: any,
                                                                                                                                                                                                                                                                                fourth: any,
                                                                                                                                                                                                                                                                                resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
                                                                                                                                                                                                                                                                                ): Observable<TResult>;
                                                                                                                                                                                                                                                                                <T2, T3, T4, T5>(
                                                                                                                                                                                                                                                                                second: any,
                                                                                                                                                                                                                                                                                third: any,
                                                                                                                                                                                                                                                                                fourth: any,
                                                                                                                                                                                                                                                                                fifth: any
                                                                                                                                                                                                                                                                                ): Observable<[T, T2, T3, T4, T5]>;
                                                                                                                                                                                                                                                                                <T2, T3, T4, T5, TResult>(
                                                                                                                                                                                                                                                                                second: any,
                                                                                                                                                                                                                                                                                third: any,
                                                                                                                                                                                                                                                                                fourth: any,
                                                                                                                                                                                                                                                                                fifth: any,
                                                                                                                                                                                                                                                                                resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult
                                                                                                                                                                                                                                                                                ): Observable<TResult>;
                                                                                                                                                                                                                                                                                <TOther, TResult>(
                                                                                                                                                                                                                                                                                second: any[],
                                                                                                                                                                                                                                                                                resultSelector: (left: T, ...right: TOther[]) => TResult
                                                                                                                                                                                                                                                                                ): Observable<TResult>;
                                                                                                                                                                                                                                                                                };

                                                                                                                                                                                                                                                                                  interface Observable

                                                                                                                                                                                                                                                                                  interface Observable<T> {}

                                                                                                                                                                                                                                                                                    method debounce

                                                                                                                                                                                                                                                                                    debounce: (dueTime: number, scheduler?: IScheduler) => Observable<T>;

                                                                                                                                                                                                                                                                                      method delay

                                                                                                                                                                                                                                                                                      delay: {
                                                                                                                                                                                                                                                                                      (dueTime: Date, scheduler?: IScheduler): Observable<T>;
                                                                                                                                                                                                                                                                                      (dueTime: number, scheduler?: IScheduler): Observable<T>;
                                                                                                                                                                                                                                                                                      };

                                                                                                                                                                                                                                                                                        method sample

                                                                                                                                                                                                                                                                                        sample: {
                                                                                                                                                                                                                                                                                        (interval: number, scheduler?: IScheduler): Observable<T>;
                                                                                                                                                                                                                                                                                        <TSample>(
                                                                                                                                                                                                                                                                                        sampler: Observable<TSample>,
                                                                                                                                                                                                                                                                                        scheduler?: IScheduler
                                                                                                                                                                                                                                                                                        ): Observable<T>;
                                                                                                                                                                                                                                                                                        };

                                                                                                                                                                                                                                                                                          method throttle

                                                                                                                                                                                                                                                                                          throttle: (dueTime: number, scheduler?: IScheduler) => Observable<T>;
                                                                                                                                                                                                                                                                                          • Deprecated

                                                                                                                                                                                                                                                                                            use #debounce or #throttleWithTimeout instead.

                                                                                                                                                                                                                                                                                          method throttleWithTimeout

                                                                                                                                                                                                                                                                                          throttleWithTimeout: (dueTime: number, scheduler?: IScheduler) => Observable<T>;

                                                                                                                                                                                                                                                                                            method timeInterval

                                                                                                                                                                                                                                                                                            timeInterval: (scheduler?: IScheduler) => Observable<TimeInterval<T>>;

                                                                                                                                                                                                                                                                                              method timeout

                                                                                                                                                                                                                                                                                              timeout: {
                                                                                                                                                                                                                                                                                              (
                                                                                                                                                                                                                                                                                              dueTime: Date,
                                                                                                                                                                                                                                                                                              other?: Observable<T>,
                                                                                                                                                                                                                                                                                              scheduler?: IScheduler
                                                                                                                                                                                                                                                                                              ): Observable<T>;
                                                                                                                                                                                                                                                                                              (
                                                                                                                                                                                                                                                                                              dueTime: number,
                                                                                                                                                                                                                                                                                              other?: Observable<T>,
                                                                                                                                                                                                                                                                                              scheduler?: IScheduler
                                                                                                                                                                                                                                                                                              ): Observable<T>;
                                                                                                                                                                                                                                                                                              };

                                                                                                                                                                                                                                                                                                method timestamp

                                                                                                                                                                                                                                                                                                timestamp: (scheduler?: IScheduler) => Observable<Timestamp<T>>;

                                                                                                                                                                                                                                                                                                  interface ObservableStatic

                                                                                                                                                                                                                                                                                                  interface ObservableStatic {}

                                                                                                                                                                                                                                                                                                    property prototype

                                                                                                                                                                                                                                                                                                    prototype: any;

                                                                                                                                                                                                                                                                                                      method catch

                                                                                                                                                                                                                                                                                                      catch: {
                                                                                                                                                                                                                                                                                                      <T>(sources: IPromise<T>[] | Observable<T>[]): Observable<T>;
                                                                                                                                                                                                                                                                                                      <T>(...sources: Observable<T>[]): Observable<T>;
                                                                                                                                                                                                                                                                                                      <T>(...sources: IPromise<T>[]): Observable<T>;
                                                                                                                                                                                                                                                                                                      };

                                                                                                                                                                                                                                                                                                        method catchError

                                                                                                                                                                                                                                                                                                        catchError: {
                                                                                                                                                                                                                                                                                                        <T>(sources: IPromise<T>[] | Observable<T>[]): Observable<T>;
                                                                                                                                                                                                                                                                                                        <T>(...sources: Observable<T>[]): Observable<T>;
                                                                                                                                                                                                                                                                                                        <T>(...sources: IPromise<T>[]): Observable<T>;
                                                                                                                                                                                                                                                                                                        };

                                                                                                                                                                                                                                                                                                          method catchException

                                                                                                                                                                                                                                                                                                          catchException: {
                                                                                                                                                                                                                                                                                                          <T>(sources: IPromise<T>[] | Observable<T>[]): Observable<T>;
                                                                                                                                                                                                                                                                                                          <T>(...sources: Observable<T>[]): Observable<T>;
                                                                                                                                                                                                                                                                                                          <T>(...sources: IPromise<T>[]): Observable<T>;
                                                                                                                                                                                                                                                                                                          };

                                                                                                                                                                                                                                                                                                            method combineLatest

                                                                                                                                                                                                                                                                                                            combineLatest: {
                                                                                                                                                                                                                                                                                                            <T, T2>(
                                                                                                                                                                                                                                                                                                            first: Observable<T> | IPromise<T>,
                                                                                                                                                                                                                                                                                                            second: Observable<T2> | IPromise<T2>
                                                                                                                                                                                                                                                                                                            ): Observable<[T, T2]>;
                                                                                                                                                                                                                                                                                                            <T, T2, TResult>(
                                                                                                                                                                                                                                                                                                            first: any,
                                                                                                                                                                                                                                                                                                            second: any,
                                                                                                                                                                                                                                                                                                            resultSelector: (v1: T, v2: T2) => TResult
                                                                                                                                                                                                                                                                                                            ): Observable<TResult>;
                                                                                                                                                                                                                                                                                                            <T, T2, T3>(first: any, second: any, third: any): Observable<[T, T2, T3]>;
                                                                                                                                                                                                                                                                                                            <T, T2, T3, TResult>(
                                                                                                                                                                                                                                                                                                            first: any,
                                                                                                                                                                                                                                                                                                            second: any,
                                                                                                                                                                                                                                                                                                            third: any,
                                                                                                                                                                                                                                                                                                            resultSelector: (v1: T, v2: T2, v3: T3) => TResult
                                                                                                                                                                                                                                                                                                            ): Observable<TResult>;
                                                                                                                                                                                                                                                                                                            <T, T2, T3, T4>(
                                                                                                                                                                                                                                                                                                            first: any,
                                                                                                                                                                                                                                                                                                            second: any,
                                                                                                                                                                                                                                                                                                            third: any,
                                                                                                                                                                                                                                                                                                            fourth: any
                                                                                                                                                                                                                                                                                                            ): Observable<[T, T2, T3, T4]>;
                                                                                                                                                                                                                                                                                                            <T, T2, T3, T4, TResult>(
                                                                                                                                                                                                                                                                                                            first: any,
                                                                                                                                                                                                                                                                                                            second: any,
                                                                                                                                                                                                                                                                                                            third: any,
                                                                                                                                                                                                                                                                                                            fourth: any,
                                                                                                                                                                                                                                                                                                            resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
                                                                                                                                                                                                                                                                                                            ): Observable<TResult>;
                                                                                                                                                                                                                                                                                                            <T, T2, T3, T4, T5>(
                                                                                                                                                                                                                                                                                                            first: any,
                                                                                                                                                                                                                                                                                                            second: any,
                                                                                                                                                                                                                                                                                                            third: any,
                                                                                                                                                                                                                                                                                                            fourth: any,
                                                                                                                                                                                                                                                                                                            fifth: any
                                                                                                                                                                                                                                                                                                            ): Observable<[T, T2, T3, T4, T5]>;
                                                                                                                                                                                                                                                                                                            <T, T2, T3, T4, T5, TResult>(
                                                                                                                                                                                                                                                                                                            first: any,
                                                                                                                                                                                                                                                                                                            second: any,
                                                                                                                                                                                                                                                                                                            third: any,
                                                                                                                                                                                                                                                                                                            fourth: any,
                                                                                                                                                                                                                                                                                                            fifth: any,
                                                                                                                                                                                                                                                                                                            resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult
                                                                                                                                                                                                                                                                                                            ): Observable<TResult>;
                                                                                                                                                                                                                                                                                                            <T>(sources: any[]): Observable<T[]>;
                                                                                                                                                                                                                                                                                                            <TOther, TResult>(
                                                                                                                                                                                                                                                                                                            sources: any[],
                                                                                                                                                                                                                                                                                                            resultSelector: (...otherValues: TOther[]) => TResult
                                                                                                                                                                                                                                                                                                            ): Observable<TResult>;
                                                                                                                                                                                                                                                                                                            };

                                                                                                                                                                                                                                                                                                              method concat

                                                                                                                                                                                                                                                                                                              concat: {
                                                                                                                                                                                                                                                                                                              <T>(...sources: Observable<T>[]): Observable<T>;
                                                                                                                                                                                                                                                                                                              <T>(...sources: IPromise<T>[]): Observable<T>;
                                                                                                                                                                                                                                                                                                              <T>(sources: IPromise<T>[] | Observable<T>[]): Observable<T>;
                                                                                                                                                                                                                                                                                                              };

                                                                                                                                                                                                                                                                                                                method create

                                                                                                                                                                                                                                                                                                                create: {
                                                                                                                                                                                                                                                                                                                <T>(subscribe: (observer: Observer<T>) => IDisposable): Observable<T>;
                                                                                                                                                                                                                                                                                                                <T>(subscribe: (observer: Observer<T>) => () => void): Observable<T>;
                                                                                                                                                                                                                                                                                                                <T>(subscribe: (observer: Observer<T>) => void): Observable<T>;
                                                                                                                                                                                                                                                                                                                };

                                                                                                                                                                                                                                                                                                                  method createWithDisposable

                                                                                                                                                                                                                                                                                                                  createWithDisposable: <T>(
                                                                                                                                                                                                                                                                                                                  subscribe: (observer: Observer<T>) => IDisposable
                                                                                                                                                                                                                                                                                                                  ) => Observable<T>;

                                                                                                                                                                                                                                                                                                                    method defer

                                                                                                                                                                                                                                                                                                                    defer: {
                                                                                                                                                                                                                                                                                                                    <T>(observableFactory: () => Observable<T>): Observable<T>;
                                                                                                                                                                                                                                                                                                                    <T>(observableFactory: () => IPromise<T>): Observable<T>;
                                                                                                                                                                                                                                                                                                                    };

                                                                                                                                                                                                                                                                                                                      method empty

                                                                                                                                                                                                                                                                                                                      empty: <T>(scheduler?: IScheduler) => Observable<T>;

                                                                                                                                                                                                                                                                                                                        method from

                                                                                                                                                                                                                                                                                                                        from: {
                                                                                                                                                                                                                                                                                                                        <T, TResult>(
                                                                                                                                                                                                                                                                                                                        array: T[],
                                                                                                                                                                                                                                                                                                                        mapFn: (value: T, index: number) => TResult,
                                                                                                                                                                                                                                                                                                                        thisArg?: any,
                                                                                                                                                                                                                                                                                                                        scheduler?: IScheduler
                                                                                                                                                                                                                                                                                                                        ): Observable<TResult>;
                                                                                                                                                                                                                                                                                                                        <T>(
                                                                                                                                                                                                                                                                                                                        array: T[],
                                                                                                                                                                                                                                                                                                                        mapFn?: (value: T, index: number) => T,
                                                                                                                                                                                                                                                                                                                        thisArg?: any,
                                                                                                                                                                                                                                                                                                                        scheduler?: IScheduler
                                                                                                                                                                                                                                                                                                                        ): Observable<T>;
                                                                                                                                                                                                                                                                                                                        <T, TResult>(
                                                                                                                                                                                                                                                                                                                        array: { [index: number]: T; length: number },
                                                                                                                                                                                                                                                                                                                        mapFn: (value: T, index: number) => TResult,
                                                                                                                                                                                                                                                                                                                        thisArg?: any,
                                                                                                                                                                                                                                                                                                                        scheduler?: IScheduler
                                                                                                                                                                                                                                                                                                                        ): Observable<TResult>;
                                                                                                                                                                                                                                                                                                                        <T>(
                                                                                                                                                                                                                                                                                                                        array: { [index: number]: T; length: number },
                                                                                                                                                                                                                                                                                                                        mapFn?: (value: T, index: number) => T,
                                                                                                                                                                                                                                                                                                                        thisArg?: any,
                                                                                                                                                                                                                                                                                                                        scheduler?: IScheduler
                                                                                                                                                                                                                                                                                                                        ): Observable<T>;
                                                                                                                                                                                                                                                                                                                        <T>(
                                                                                                                                                                                                                                                                                                                        iterable: any,
                                                                                                                                                                                                                                                                                                                        mapFn?: (value: any, index: number) => T,
                                                                                                                                                                                                                                                                                                                        thisArg?: any,
                                                                                                                                                                                                                                                                                                                        scheduler?: IScheduler
                                                                                                                                                                                                                                                                                                                        ): Observable<T>;
                                                                                                                                                                                                                                                                                                                        };
                                                                                                                                                                                                                                                                                                                        • This method creates a new Observable sequence from an array object.

                                                                                                                                                                                                                                                                                                                          Parameter array

                                                                                                                                                                                                                                                                                                                          An array-like or iterable object to convert to an Observable sequence.

                                                                                                                                                                                                                                                                                                                          Parameter mapFn

                                                                                                                                                                                                                                                                                                                          Map function to call on every element of the array.

                                                                                                                                                                                                                                                                                                                          Parameter thisArg

                                                                                                                                                                                                                                                                                                                          The context to use calling the mapFn if provided.

                                                                                                                                                                                                                                                                                                                          Parameter scheduler

                                                                                                                                                                                                                                                                                                                          Optional scheduler to use for scheduling. If not provided, defaults to Scheduler.currentThread.

                                                                                                                                                                                                                                                                                                                        • This method creates a new Observable sequence from an array object.

                                                                                                                                                                                                                                                                                                                          Parameter array

                                                                                                                                                                                                                                                                                                                          An array-like or iterable object to convert to an Observable sequence.

                                                                                                                                                                                                                                                                                                                          Parameter mapFn

                                                                                                                                                                                                                                                                                                                          Map function to call on every element of the array.

                                                                                                                                                                                                                                                                                                                          Parameter thisArg

                                                                                                                                                                                                                                                                                                                          The context to use calling the mapFn if provided.

                                                                                                                                                                                                                                                                                                                          Parameter scheduler

                                                                                                                                                                                                                                                                                                                          Optional scheduler to use for scheduling. If not provided, defaults to Scheduler.currentThread.

                                                                                                                                                                                                                                                                                                                        • This method creates a new Observable sequence from an array-like object.

                                                                                                                                                                                                                                                                                                                          Parameter array

                                                                                                                                                                                                                                                                                                                          An array-like or iterable object to convert to an Observable sequence.

                                                                                                                                                                                                                                                                                                                          Parameter mapFn

                                                                                                                                                                                                                                                                                                                          Map function to call on every element of the array.

                                                                                                                                                                                                                                                                                                                          Parameter thisArg

                                                                                                                                                                                                                                                                                                                          The context to use calling the mapFn if provided.

                                                                                                                                                                                                                                                                                                                          Parameter scheduler

                                                                                                                                                                                                                                                                                                                          Optional scheduler to use for scheduling. If not provided, defaults to Scheduler.currentThread.

                                                                                                                                                                                                                                                                                                                        • This method creates a new Observable sequence from an array-like object.

                                                                                                                                                                                                                                                                                                                          Parameter array

                                                                                                                                                                                                                                                                                                                          An array-like or iterable object to convert to an Observable sequence.

                                                                                                                                                                                                                                                                                                                          Parameter mapFn

                                                                                                                                                                                                                                                                                                                          Map function to call on every element of the array.

                                                                                                                                                                                                                                                                                                                          Parameter thisArg

                                                                                                                                                                                                                                                                                                                          The context to use calling the mapFn if provided.

                                                                                                                                                                                                                                                                                                                          Parameter scheduler

                                                                                                                                                                                                                                                                                                                          Optional scheduler to use for scheduling. If not provided, defaults to Scheduler.currentThread.

                                                                                                                                                                                                                                                                                                                        • This method creates a new Observable sequence from an array-like or iterable object.

                                                                                                                                                                                                                                                                                                                          Parameter array

                                                                                                                                                                                                                                                                                                                          An array-like or iterable object to convert to an Observable sequence.

                                                                                                                                                                                                                                                                                                                          Parameter mapFn

                                                                                                                                                                                                                                                                                                                          Map function to call on every element of the array.

                                                                                                                                                                                                                                                                                                                          Parameter thisArg

                                                                                                                                                                                                                                                                                                                          The context to use calling the mapFn if provided.

                                                                                                                                                                                                                                                                                                                          Parameter scheduler

                                                                                                                                                                                                                                                                                                                          Optional scheduler to use for scheduling. If not provided, defaults to Scheduler.currentThread.

                                                                                                                                                                                                                                                                                                                        method fromArray

                                                                                                                                                                                                                                                                                                                        fromArray: {
                                                                                                                                                                                                                                                                                                                        <T>(array: T[], scheduler?: IScheduler): Observable<T>;
                                                                                                                                                                                                                                                                                                                        <T>(
                                                                                                                                                                                                                                                                                                                        array: { [index: number]: T; length: number },
                                                                                                                                                                                                                                                                                                                        scheduler?: IScheduler
                                                                                                                                                                                                                                                                                                                        ): Observable<T>;
                                                                                                                                                                                                                                                                                                                        };

                                                                                                                                                                                                                                                                                                                          method fromPromise

                                                                                                                                                                                                                                                                                                                          fromPromise: <T>(promise: IPromise<T>) => Observable<T>;
                                                                                                                                                                                                                                                                                                                          • Converts a Promise to an Observable sequence

                                                                                                                                                                                                                                                                                                                            Parameter promise

                                                                                                                                                                                                                                                                                                                            An ES6 Compliant promise.

                                                                                                                                                                                                                                                                                                                            Returns

                                                                                                                                                                                                                                                                                                                            An Observable sequence which wraps the existing promise success and failure.

                                                                                                                                                                                                                                                                                                                          method generate

                                                                                                                                                                                                                                                                                                                          generate: <TState, TResult>(
                                                                                                                                                                                                                                                                                                                          initialState: TState,
                                                                                                                                                                                                                                                                                                                          condition: (state: TState) => boolean,
                                                                                                                                                                                                                                                                                                                          iterate: (state: TState) => TState,
                                                                                                                                                                                                                                                                                                                          resultSelector: (state: TState) => TResult,
                                                                                                                                                                                                                                                                                                                          scheduler?: IScheduler
                                                                                                                                                                                                                                                                                                                          ) => Observable<TResult>;

                                                                                                                                                                                                                                                                                                                            method just

                                                                                                                                                                                                                                                                                                                            just: <T>(value: T, scheduler?: IScheduler) => Observable<T>;
                                                                                                                                                                                                                                                                                                                            • 2.2.28

                                                                                                                                                                                                                                                                                                                            method merge

                                                                                                                                                                                                                                                                                                                            merge: {
                                                                                                                                                                                                                                                                                                                            <T>(...sources: Observable<T>[]): Observable<T>;
                                                                                                                                                                                                                                                                                                                            <T>(...sources: IPromise<T>[]): Observable<T>;
                                                                                                                                                                                                                                                                                                                            <T>(sources: IPromise<T>[] | Observable<T>[]): Observable<T>;
                                                                                                                                                                                                                                                                                                                            <T>(scheduler: IScheduler, ...sources: Observable<T>[]): Observable<T>;
                                                                                                                                                                                                                                                                                                                            <T>(scheduler: IScheduler, ...sources: IPromise<T>[]): Observable<T>;
                                                                                                                                                                                                                                                                                                                            <T>(
                                                                                                                                                                                                                                                                                                                            scheduler: IScheduler,
                                                                                                                                                                                                                                                                                                                            sources: IPromise<T>[] | Observable<T>[]
                                                                                                                                                                                                                                                                                                                            ): Observable<T>;
                                                                                                                                                                                                                                                                                                                            };

                                                                                                                                                                                                                                                                                                                              method never

                                                                                                                                                                                                                                                                                                                              never: <T>() => Observable<T>;

                                                                                                                                                                                                                                                                                                                                method of

                                                                                                                                                                                                                                                                                                                                of: <T>(...values: T[]) => Observable<T>;
                                                                                                                                                                                                                                                                                                                                • This method creates a new Observable instance with a variable number of arguments, regardless of number or type of the arguments.

                                                                                                                                                                                                                                                                                                                                  Returns

                                                                                                                                                                                                                                                                                                                                  The observable sequence whose elements are pulled from the given arguments.

                                                                                                                                                                                                                                                                                                                                  Example 1

                                                                                                                                                                                                                                                                                                                                  var res = Rx.Observable.of(1, 2, 3); 2.2.28

                                                                                                                                                                                                                                                                                                                                method ofWithScheduler

                                                                                                                                                                                                                                                                                                                                ofWithScheduler: <T>(scheduler?: IScheduler, ...values: T[]) => Observable<T>;
                                                                                                                                                                                                                                                                                                                                • This method creates a new Observable instance with a variable number of arguments, regardless of number or type of the arguments.

                                                                                                                                                                                                                                                                                                                                  Parameter scheduler

                                                                                                                                                                                                                                                                                                                                  A scheduler to use for scheduling the arguments.

                                                                                                                                                                                                                                                                                                                                  Returns

                                                                                                                                                                                                                                                                                                                                  The observable sequence whose elements are pulled from the given arguments.

                                                                                                                                                                                                                                                                                                                                  Example 1

                                                                                                                                                                                                                                                                                                                                  var res = Rx.Observable.ofWithScheduler(Rx.Scheduler.timeout, 1, 2, 3); 2.2.28

                                                                                                                                                                                                                                                                                                                                method pairs

                                                                                                                                                                                                                                                                                                                                pairs: <T>(
                                                                                                                                                                                                                                                                                                                                obj: { [key: string]: T },
                                                                                                                                                                                                                                                                                                                                scheduler?: IScheduler
                                                                                                                                                                                                                                                                                                                                ) => Observable<[string, T]>;

                                                                                                                                                                                                                                                                                                                                  method range

                                                                                                                                                                                                                                                                                                                                  range: (
                                                                                                                                                                                                                                                                                                                                  start: number,
                                                                                                                                                                                                                                                                                                                                  count: number,
                                                                                                                                                                                                                                                                                                                                  scheduler?: IScheduler
                                                                                                                                                                                                                                                                                                                                  ) => Observable<number>;

                                                                                                                                                                                                                                                                                                                                    method repeat

                                                                                                                                                                                                                                                                                                                                    repeat: <T>(
                                                                                                                                                                                                                                                                                                                                    value: T,
                                                                                                                                                                                                                                                                                                                                    repeatCount?: number,
                                                                                                                                                                                                                                                                                                                                    scheduler?: IScheduler
                                                                                                                                                                                                                                                                                                                                    ) => Observable<T>;

                                                                                                                                                                                                                                                                                                                                      method return

                                                                                                                                                                                                                                                                                                                                      return: <T>(value: T, scheduler?: IScheduler) => Observable<T>;

                                                                                                                                                                                                                                                                                                                                        method returnValue

                                                                                                                                                                                                                                                                                                                                        returnValue: <T>(value: T, scheduler?: IScheduler) => Observable<T>;

                                                                                                                                                                                                                                                                                                                                          method throw

                                                                                                                                                                                                                                                                                                                                          throw: <T>(exception: Error, scheduler?: IScheduler) => Observable<T>;

                                                                                                                                                                                                                                                                                                                                            method throwError

                                                                                                                                                                                                                                                                                                                                            throwError: <T>(error: Error, scheduler?: IScheduler) => Observable<T>;

                                                                                                                                                                                                                                                                                                                                              method throwException

                                                                                                                                                                                                                                                                                                                                              throwException: <T>(exception: Error, scheduler?: IScheduler) => Observable<T>;

                                                                                                                                                                                                                                                                                                                                                method withLatestFrom

                                                                                                                                                                                                                                                                                                                                                withLatestFrom: {
                                                                                                                                                                                                                                                                                                                                                <T, T2>(
                                                                                                                                                                                                                                                                                                                                                first: Observable<T> | IPromise<T>,
                                                                                                                                                                                                                                                                                                                                                second: Observable<T2> | IPromise<T2>
                                                                                                                                                                                                                                                                                                                                                ): Observable<[T, T2]>;
                                                                                                                                                                                                                                                                                                                                                <T, T2, TResult>(
                                                                                                                                                                                                                                                                                                                                                first: any,
                                                                                                                                                                                                                                                                                                                                                second: any,
                                                                                                                                                                                                                                                                                                                                                resultSelector: (v1: T, v2: T2) => TResult
                                                                                                                                                                                                                                                                                                                                                ): Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                <T, T2, T3>(first: any, second: any, third: any): Observable<[T, T2, T3]>;
                                                                                                                                                                                                                                                                                                                                                <T, T2, T3, TResult>(
                                                                                                                                                                                                                                                                                                                                                first: any,
                                                                                                                                                                                                                                                                                                                                                second: any,
                                                                                                                                                                                                                                                                                                                                                third: any,
                                                                                                                                                                                                                                                                                                                                                resultSelector: (v1: T, v2: T2, v3: T3) => TResult
                                                                                                                                                                                                                                                                                                                                                ): Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                <T, T2, T3, T4>(
                                                                                                                                                                                                                                                                                                                                                first: any,
                                                                                                                                                                                                                                                                                                                                                second: any,
                                                                                                                                                                                                                                                                                                                                                third: any,
                                                                                                                                                                                                                                                                                                                                                fourth: any
                                                                                                                                                                                                                                                                                                                                                ): Observable<[T, T2, T3, T4]>;
                                                                                                                                                                                                                                                                                                                                                <T, T2, T3, T4, TResult>(
                                                                                                                                                                                                                                                                                                                                                first: any,
                                                                                                                                                                                                                                                                                                                                                second: any,
                                                                                                                                                                                                                                                                                                                                                third: any,
                                                                                                                                                                                                                                                                                                                                                fourth: any,
                                                                                                                                                                                                                                                                                                                                                resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
                                                                                                                                                                                                                                                                                                                                                ): Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                <T, T2, T3, T4, T5>(
                                                                                                                                                                                                                                                                                                                                                first: any,
                                                                                                                                                                                                                                                                                                                                                second: any,
                                                                                                                                                                                                                                                                                                                                                third: any,
                                                                                                                                                                                                                                                                                                                                                fourth: any,
                                                                                                                                                                                                                                                                                                                                                fifth: any
                                                                                                                                                                                                                                                                                                                                                ): Observable<[T, T2, T3, T4, T5]>;
                                                                                                                                                                                                                                                                                                                                                <T, T2, T3, T4, T5, TResult>(
                                                                                                                                                                                                                                                                                                                                                first: any,
                                                                                                                                                                                                                                                                                                                                                second: any,
                                                                                                                                                                                                                                                                                                                                                third: any,
                                                                                                                                                                                                                                                                                                                                                fourth: any,
                                                                                                                                                                                                                                                                                                                                                fifth: any,
                                                                                                                                                                                                                                                                                                                                                resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult
                                                                                                                                                                                                                                                                                                                                                ): Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                <TOther, TResult>(
                                                                                                                                                                                                                                                                                                                                                souces: any[],
                                                                                                                                                                                                                                                                                                                                                resultSelector: (...otherValues: TOther[]) => TResult
                                                                                                                                                                                                                                                                                                                                                ): Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                };

                                                                                                                                                                                                                                                                                                                                                  method zip

                                                                                                                                                                                                                                                                                                                                                  zip: {
                                                                                                                                                                                                                                                                                                                                                  <T1, T2>(
                                                                                                                                                                                                                                                                                                                                                  first: Observable<T1> | IPromise<T1>,
                                                                                                                                                                                                                                                                                                                                                  sources:
                                                                                                                                                                                                                                                                                                                                                  | Observable<T2>
                                                                                                                                                                                                                                                                                                                                                  | IPromise<T2>
                                                                                                                                                                                                                                                                                                                                                  | (Observable<T2> | IPromise<T2>)[]
                                                                                                                                                                                                                                                                                                                                                  ): Observable<[T1, T2]>;
                                                                                                                                                                                                                                                                                                                                                  <T1, T2, TResult>(
                                                                                                                                                                                                                                                                                                                                                  first: any,
                                                                                                                                                                                                                                                                                                                                                  sources: any[],
                                                                                                                                                                                                                                                                                                                                                  resultSelector: (item1: T1, ...right: T2[]) => TResult
                                                                                                                                                                                                                                                                                                                                                  ): Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                  <T1, T2, TResult>(
                                                                                                                                                                                                                                                                                                                                                  source1: any,
                                                                                                                                                                                                                                                                                                                                                  source2: any,
                                                                                                                                                                                                                                                                                                                                                  resultSelector: (item1: T1, item2: T2) => TResult
                                                                                                                                                                                                                                                                                                                                                  ): Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                  <T1, T2, T3>(source1: any, source2: any, source3: any): Observable<
                                                                                                                                                                                                                                                                                                                                                  [T1, T2, T3]
                                                                                                                                                                                                                                                                                                                                                  >;
                                                                                                                                                                                                                                                                                                                                                  <T1, T2, T3, TResult>(
                                                                                                                                                                                                                                                                                                                                                  source1: any,
                                                                                                                                                                                                                                                                                                                                                  source2: any,
                                                                                                                                                                                                                                                                                                                                                  source3: any,
                                                                                                                                                                                                                                                                                                                                                  resultSelector: (item1: T1, item2: T2, item3: T3) => TResult
                                                                                                                                                                                                                                                                                                                                                  ): Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                  <T1, T2, T3, T4>(
                                                                                                                                                                                                                                                                                                                                                  source1: any,
                                                                                                                                                                                                                                                                                                                                                  source2: any,
                                                                                                                                                                                                                                                                                                                                                  source3: any,
                                                                                                                                                                                                                                                                                                                                                  source4: any
                                                                                                                                                                                                                                                                                                                                                  ): Observable<[T1, T2, T3, T4]>;
                                                                                                                                                                                                                                                                                                                                                  <T1, T2, T3, T4, TResult>(
                                                                                                                                                                                                                                                                                                                                                  source1: any,
                                                                                                                                                                                                                                                                                                                                                  source2: any,
                                                                                                                                                                                                                                                                                                                                                  source3: any,
                                                                                                                                                                                                                                                                                                                                                  source4: any,
                                                                                                                                                                                                                                                                                                                                                  resultSelector: (item1: T1, item2: T2, item3: T3, item4: T4) => TResult
                                                                                                                                                                                                                                                                                                                                                  ): Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                  <T1, T2, T3, T4, T5>(
                                                                                                                                                                                                                                                                                                                                                  source1: any,
                                                                                                                                                                                                                                                                                                                                                  source2: any,
                                                                                                                                                                                                                                                                                                                                                  source3: any,
                                                                                                                                                                                                                                                                                                                                                  source4: any,
                                                                                                                                                                                                                                                                                                                                                  source5: any
                                                                                                                                                                                                                                                                                                                                                  ): Observable<[T1, T2, T3, T4, T5]>;
                                                                                                                                                                                                                                                                                                                                                  <T1, T2, T3, T4, T5, TResult>(
                                                                                                                                                                                                                                                                                                                                                  source1: any,
                                                                                                                                                                                                                                                                                                                                                  source2: any,
                                                                                                                                                                                                                                                                                                                                                  source3: any,
                                                                                                                                                                                                                                                                                                                                                  source4: any,
                                                                                                                                                                                                                                                                                                                                                  source5: any,
                                                                                                                                                                                                                                                                                                                                                  resultSelector: (
                                                                                                                                                                                                                                                                                                                                                  item1: T1,
                                                                                                                                                                                                                                                                                                                                                  item2: T2,
                                                                                                                                                                                                                                                                                                                                                  item3: T3,
                                                                                                                                                                                                                                                                                                                                                  item4: T4,
                                                                                                                                                                                                                                                                                                                                                  item5: T5
                                                                                                                                                                                                                                                                                                                                                  ) => TResult
                                                                                                                                                                                                                                                                                                                                                  ): Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                  };

                                                                                                                                                                                                                                                                                                                                                    method zipArray

                                                                                                                                                                                                                                                                                                                                                    zipArray: {
                                                                                                                                                                                                                                                                                                                                                    <T>(...sources: (Observable<T> | IPromise<T>)[]): Observable<T[]>;
                                                                                                                                                                                                                                                                                                                                                    <T>(sources: any[]): Observable<T[]>;
                                                                                                                                                                                                                                                                                                                                                    };

                                                                                                                                                                                                                                                                                                                                                      interface ObservableStatic

                                                                                                                                                                                                                                                                                                                                                      interface ObservableStatic {}

                                                                                                                                                                                                                                                                                                                                                        property fromCallback

                                                                                                                                                                                                                                                                                                                                                        fromCallback: {
                                                                                                                                                                                                                                                                                                                                                        // with single result callback without selector
                                                                                                                                                                                                                                                                                                                                                        <TResult>(
                                                                                                                                                                                                                                                                                                                                                        func: (callback: (result: TResult) => any) => any,
                                                                                                                                                                                                                                                                                                                                                        context?: any
                                                                                                                                                                                                                                                                                                                                                        ): () => Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                        <T1, TResult>(
                                                                                                                                                                                                                                                                                                                                                        func: (arg1: T1, callback: (result: TResult) => any) => any,
                                                                                                                                                                                                                                                                                                                                                        context?: any
                                                                                                                                                                                                                                                                                                                                                        ): (arg1: T1) => Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                        <T1, T2, TResult>(
                                                                                                                                                                                                                                                                                                                                                        func: (arg1: T1, arg2: T2, callback: (result: TResult) => any) => any,
                                                                                                                                                                                                                                                                                                                                                        context?: any
                                                                                                                                                                                                                                                                                                                                                        ): (arg1: T1, arg2: T2) => Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                        <T1, T2, T3, TResult>(
                                                                                                                                                                                                                                                                                                                                                        func: (
                                                                                                                                                                                                                                                                                                                                                        arg1: T1,
                                                                                                                                                                                                                                                                                                                                                        arg2: T2,
                                                                                                                                                                                                                                                                                                                                                        arg3: T3,
                                                                                                                                                                                                                                                                                                                                                        callback: (result: TResult) => any
                                                                                                                                                                                                                                                                                                                                                        ) => any,
                                                                                                                                                                                                                                                                                                                                                        context?: any
                                                                                                                                                                                                                                                                                                                                                        ): (arg1: T1, arg2: T2, arg3: T3) => Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                        // with any callback with selector
                                                                                                                                                                                                                                                                                                                                                        <TCallbackResult, TResult>(
                                                                                                                                                                                                                                                                                                                                                        func: (callback: Function) => any,
                                                                                                                                                                                                                                                                                                                                                        context: any,
                                                                                                                                                                                                                                                                                                                                                        selector: (args: TCallbackResult[]) => TResult
                                                                                                                                                                                                                                                                                                                                                        ): () => Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                        <T1, TCallbackResult, TResult>(
                                                                                                                                                                                                                                                                                                                                                        func: (arg1: T1, callback: Function) => any,
                                                                                                                                                                                                                                                                                                                                                        context: any,
                                                                                                                                                                                                                                                                                                                                                        selector: (args: TCallbackResult[]) => TResult
                                                                                                                                                                                                                                                                                                                                                        ): (arg1: T1) => Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                        <T1, T2, TCallbackResult, TResult>(
                                                                                                                                                                                                                                                                                                                                                        func: (arg1: T1, arg2: T2, callback: Function) => any,
                                                                                                                                                                                                                                                                                                                                                        context: any,
                                                                                                                                                                                                                                                                                                                                                        selector: (args: TCallbackResult[]) => TResult
                                                                                                                                                                                                                                                                                                                                                        ): (arg1: T1, arg2: T2) => Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                        <T1, T2, T3, TCallbackResult, TResult>(
                                                                                                                                                                                                                                                                                                                                                        func: (arg1: T1, arg2: T2, arg3: T3, callback: Function) => any,
                                                                                                                                                                                                                                                                                                                                                        context: any,
                                                                                                                                                                                                                                                                                                                                                        selector: (args: TCallbackResult[]) => TResult
                                                                                                                                                                                                                                                                                                                                                        ): (arg1: T1, arg2: T2, arg3: T3) => Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                        // with any callback without selector
                                                                                                                                                                                                                                                                                                                                                        <TResult>(
                                                                                                                                                                                                                                                                                                                                                        func: (callback: Function) => any,
                                                                                                                                                                                                                                                                                                                                                        context?: any
                                                                                                                                                                                                                                                                                                                                                        ): () => Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                        <T1, TResult>(func: (arg1: T1, callback: Function) => any, context?: any): (
                                                                                                                                                                                                                                                                                                                                                        arg1: T1
                                                                                                                                                                                                                                                                                                                                                        ) => Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                        <T1, T2, TResult>(
                                                                                                                                                                                                                                                                                                                                                        func: (arg1: T1, arg2: T2, callback: Function) => any,
                                                                                                                                                                                                                                                                                                                                                        context?: any
                                                                                                                                                                                                                                                                                                                                                        ): (arg1: T1, arg2: T2) => Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                        <T1, T2, T3, TResult>(
                                                                                                                                                                                                                                                                                                                                                        func: (arg1: T1, arg2: T2, arg3: T3, callback: Function) => any,
                                                                                                                                                                                                                                                                                                                                                        context?: any
                                                                                                                                                                                                                                                                                                                                                        ): (arg1: T1, arg2: T2, arg3: T3) => Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                        // with any function with selector
                                                                                                                                                                                                                                                                                                                                                        <TCallbackResult, TResult>(
                                                                                                                                                                                                                                                                                                                                                        func: Function,
                                                                                                                                                                                                                                                                                                                                                        context: any,
                                                                                                                                                                                                                                                                                                                                                        selector: (args: TCallbackResult[]) => TResult
                                                                                                                                                                                                                                                                                                                                                        ): (...args: any[]) => Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                        // with any function without selector
                                                                                                                                                                                                                                                                                                                                                        <TResult>(func: Function, context?: any): (
                                                                                                                                                                                                                                                                                                                                                        ...args: any[]
                                                                                                                                                                                                                                                                                                                                                        ) => Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                        };

                                                                                                                                                                                                                                                                                                                                                          property fromNodeCallback

                                                                                                                                                                                                                                                                                                                                                          fromNodeCallback: {
                                                                                                                                                                                                                                                                                                                                                          // with single result callback without selector
                                                                                                                                                                                                                                                                                                                                                          <T>(
                                                                                                                                                                                                                                                                                                                                                          func: (callback: (err: any, result: T) => any) => any,
                                                                                                                                                                                                                                                                                                                                                          context?: any
                                                                                                                                                                                                                                                                                                                                                          ): () => Observable<T>;
                                                                                                                                                                                                                                                                                                                                                          <T1, T>(
                                                                                                                                                                                                                                                                                                                                                          func: (arg1: T1, callback: (err: any, result: T) => any) => any,
                                                                                                                                                                                                                                                                                                                                                          context?: any
                                                                                                                                                                                                                                                                                                                                                          ): (arg1: T1) => Observable<T>;
                                                                                                                                                                                                                                                                                                                                                          <T1, T2, T>(
                                                                                                                                                                                                                                                                                                                                                          func: (
                                                                                                                                                                                                                                                                                                                                                          arg1: T1,
                                                                                                                                                                                                                                                                                                                                                          arg2: T2,
                                                                                                                                                                                                                                                                                                                                                          callback: (err: any, result: T) => any
                                                                                                                                                                                                                                                                                                                                                          ) => any,
                                                                                                                                                                                                                                                                                                                                                          context?: any
                                                                                                                                                                                                                                                                                                                                                          ): (arg1: T1, arg2: T2) => Observable<T>;
                                                                                                                                                                                                                                                                                                                                                          <T1, T2, T3, T>(
                                                                                                                                                                                                                                                                                                                                                          func: (
                                                                                                                                                                                                                                                                                                                                                          arg1: T1,
                                                                                                                                                                                                                                                                                                                                                          arg2: T2,
                                                                                                                                                                                                                                                                                                                                                          arg3: T3,
                                                                                                                                                                                                                                                                                                                                                          callback: (err: any, result: T) => any
                                                                                                                                                                                                                                                                                                                                                          ) => any,
                                                                                                                                                                                                                                                                                                                                                          context?: any
                                                                                                                                                                                                                                                                                                                                                          ): (arg1: T1, arg2: T2, arg3: T3) => Observable<T>;
                                                                                                                                                                                                                                                                                                                                                          // with any callback with selector
                                                                                                                                                                                                                                                                                                                                                          <TC, TR>(
                                                                                                                                                                                                                                                                                                                                                          func: (callback: Function) => any,
                                                                                                                                                                                                                                                                                                                                                          context: any,
                                                                                                                                                                                                                                                                                                                                                          selector: (results: TC[]) => TR
                                                                                                                                                                                                                                                                                                                                                          ): () => Observable<TR>;
                                                                                                                                                                                                                                                                                                                                                          <T1, TC, TR>(
                                                                                                                                                                                                                                                                                                                                                          func: (arg1: T1, callback: Function) => any,
                                                                                                                                                                                                                                                                                                                                                          context: any,
                                                                                                                                                                                                                                                                                                                                                          selector: (results: TC[]) => TR
                                                                                                                                                                                                                                                                                                                                                          ): (arg1: T1) => Observable<TR>;
                                                                                                                                                                                                                                                                                                                                                          <T1, T2, TC, TR>(
                                                                                                                                                                                                                                                                                                                                                          func: (arg1: T1, arg2: T2, callback: Function) => any,
                                                                                                                                                                                                                                                                                                                                                          context: any,
                                                                                                                                                                                                                                                                                                                                                          selector: (results: TC[]) => TR
                                                                                                                                                                                                                                                                                                                                                          ): (arg1: T1, arg2: T2) => Observable<TR>;
                                                                                                                                                                                                                                                                                                                                                          <T1, T2, T3, TC, TR>(
                                                                                                                                                                                                                                                                                                                                                          func: (arg1: T1, arg2: T2, arg3: T3, callback: Function) => any,
                                                                                                                                                                                                                                                                                                                                                          context: any,
                                                                                                                                                                                                                                                                                                                                                          selector: (results: TC[]) => TR
                                                                                                                                                                                                                                                                                                                                                          ): (arg1: T1, arg2: T2, arg3: T3) => Observable<TR>;
                                                                                                                                                                                                                                                                                                                                                          // with any callback without selector
                                                                                                                                                                                                                                                                                                                                                          <TR>(func: (callback: Function) => any, context?: any): () => Observable<TR>;
                                                                                                                                                                                                                                                                                                                                                          <T1, TR>(func: (arg1: T1, callback: Function) => any, context?: any): (
                                                                                                                                                                                                                                                                                                                                                          arg1: T1
                                                                                                                                                                                                                                                                                                                                                          ) => Observable<TR>;
                                                                                                                                                                                                                                                                                                                                                          <T1, T2, TR>(
                                                                                                                                                                                                                                                                                                                                                          func: (arg1: T1, arg2: T2, callback: Function) => any,
                                                                                                                                                                                                                                                                                                                                                          context?: any
                                                                                                                                                                                                                                                                                                                                                          ): (arg1: T1, arg2: T2) => Observable<TR>;
                                                                                                                                                                                                                                                                                                                                                          <T1, T2, T3, TR>(
                                                                                                                                                                                                                                                                                                                                                          func: (arg1: T1, arg2: T2, arg3: T3, callback: Function) => any,
                                                                                                                                                                                                                                                                                                                                                          context?: any
                                                                                                                                                                                                                                                                                                                                                          ): (arg1: T1, arg2: T2, arg3: T3) => Observable<TR>;
                                                                                                                                                                                                                                                                                                                                                          // with any function with selector
                                                                                                                                                                                                                                                                                                                                                          <TC, T>(func: Function, context: any, selector: (results: TC[]) => T): (
                                                                                                                                                                                                                                                                                                                                                          ...args: any[]
                                                                                                                                                                                                                                                                                                                                                          ) => Observable<T>;
                                                                                                                                                                                                                                                                                                                                                          // with any function without selector
                                                                                                                                                                                                                                                                                                                                                          <T>(func: Function, context?: any): (...args: any[]) => Observable<T>;
                                                                                                                                                                                                                                                                                                                                                          };

                                                                                                                                                                                                                                                                                                                                                            method fromEvent

                                                                                                                                                                                                                                                                                                                                                            fromEvent: <T>(
                                                                                                                                                                                                                                                                                                                                                            element:
                                                                                                                                                                                                                                                                                                                                                            | ArrayLike<DOMEventTarget>
                                                                                                                                                                                                                                                                                                                                                            | DOMEventTarget
                                                                                                                                                                                                                                                                                                                                                            | NodeEventTarget
                                                                                                                                                                                                                                                                                                                                                            | NativeEventTarget,
                                                                                                                                                                                                                                                                                                                                                            eventName: string,
                                                                                                                                                                                                                                                                                                                                                            selector?: (...args: any[]) => T
                                                                                                                                                                                                                                                                                                                                                            ) => Observable<T>;

                                                                                                                                                                                                                                                                                                                                                              method fromEventPattern

                                                                                                                                                                                                                                                                                                                                                              fromEventPattern: <T>(
                                                                                                                                                                                                                                                                                                                                                              addHandler: (handler: Function) => void,
                                                                                                                                                                                                                                                                                                                                                              removeHandler: (handler: Function) => void,
                                                                                                                                                                                                                                                                                                                                                              selector?: (...args: any[]) => T
                                                                                                                                                                                                                                                                                                                                                              ) => Observable<T>;

                                                                                                                                                                                                                                                                                                                                                                interface ObservableStatic

                                                                                                                                                                                                                                                                                                                                                                interface ObservableStatic {}

                                                                                                                                                                                                                                                                                                                                                                  method interval

                                                                                                                                                                                                                                                                                                                                                                  interval: {
                                                                                                                                                                                                                                                                                                                                                                  (period: number, scheduler?: IScheduler): Observable<number>;
                                                                                                                                                                                                                                                                                                                                                                  (
                                                                                                                                                                                                                                                                                                                                                                  dutTime: number,
                                                                                                                                                                                                                                                                                                                                                                  period: number,
                                                                                                                                                                                                                                                                                                                                                                  scheduler?: IScheduler
                                                                                                                                                                                                                                                                                                                                                                  ): Observable<number>;
                                                                                                                                                                                                                                                                                                                                                                  };

                                                                                                                                                                                                                                                                                                                                                                    method timer

                                                                                                                                                                                                                                                                                                                                                                    timer: {
                                                                                                                                                                                                                                                                                                                                                                    (
                                                                                                                                                                                                                                                                                                                                                                    dueTime: number,
                                                                                                                                                                                                                                                                                                                                                                    period: number,
                                                                                                                                                                                                                                                                                                                                                                    scheduler?: IScheduler
                                                                                                                                                                                                                                                                                                                                                                    ): Observable<number>;
                                                                                                                                                                                                                                                                                                                                                                    (dueTime: number, scheduler?: IScheduler): Observable<number>;
                                                                                                                                                                                                                                                                                                                                                                    };

                                                                                                                                                                                                                                                                                                                                                                      interface Observer

                                                                                                                                                                                                                                                                                                                                                                      interface Observer<T> extends IObserver<T> {}

                                                                                                                                                                                                                                                                                                                                                                        method asObserver

                                                                                                                                                                                                                                                                                                                                                                        asObserver: () => Observer<T>;

                                                                                                                                                                                                                                                                                                                                                                          method toNotifier

                                                                                                                                                                                                                                                                                                                                                                          toNotifier: () => (notification: Notification<T>) => void;

                                                                                                                                                                                                                                                                                                                                                                            interface ObserverStatic

                                                                                                                                                                                                                                                                                                                                                                            interface ObserverStatic {}

                                                                                                                                                                                                                                                                                                                                                                              method create

                                                                                                                                                                                                                                                                                                                                                                              create: <T>(
                                                                                                                                                                                                                                                                                                                                                                              onNext?: (value: T) => void,
                                                                                                                                                                                                                                                                                                                                                                              onError?: (exception: any) => void,
                                                                                                                                                                                                                                                                                                                                                                              onCompleted?: () => void
                                                                                                                                                                                                                                                                                                                                                                              ) => Observer<T>;

                                                                                                                                                                                                                                                                                                                                                                                method fromNotifier

                                                                                                                                                                                                                                                                                                                                                                                fromNotifier: <T>(
                                                                                                                                                                                                                                                                                                                                                                                handler: (notification: Notification<T>, thisArg?: any) => void
                                                                                                                                                                                                                                                                                                                                                                                ) => Observer<T>;

                                                                                                                                                                                                                                                                                                                                                                                  interface Scheduler

                                                                                                                                                                                                                                                                                                                                                                                  interface Scheduler extends IScheduler {}

                                                                                                                                                                                                                                                                                                                                                                                    interface SchedulerStatic

                                                                                                                                                                                                                                                                                                                                                                                    interface SchedulerStatic {}

                                                                                                                                                                                                                                                                                                                                                                                      property currentThread

                                                                                                                                                                                                                                                                                                                                                                                      currentThread: ICurrentThreadScheduler;

                                                                                                                                                                                                                                                                                                                                                                                        property default

                                                                                                                                                                                                                                                                                                                                                                                        default: IScheduler;

                                                                                                                                                                                                                                                                                                                                                                                          property immediate

                                                                                                                                                                                                                                                                                                                                                                                          immediate: IScheduler;

                                                                                                                                                                                                                                                                                                                                                                                            property timeout

                                                                                                                                                                                                                                                                                                                                                                                            timeout: IScheduler;

                                                                                                                                                                                                                                                                                                                                                                                              method normalize

                                                                                                                                                                                                                                                                                                                                                                                              normalize: (timeSpan: number) => number;

                                                                                                                                                                                                                                                                                                                                                                                                construct signature

                                                                                                                                                                                                                                                                                                                                                                                                new (
                                                                                                                                                                                                                                                                                                                                                                                                now: () => number,
                                                                                                                                                                                                                                                                                                                                                                                                schedule: (
                                                                                                                                                                                                                                                                                                                                                                                                state: any,
                                                                                                                                                                                                                                                                                                                                                                                                action: (scheduler: IScheduler, state: any) => IDisposable
                                                                                                                                                                                                                                                                                                                                                                                                ) => IDisposable,
                                                                                                                                                                                                                                                                                                                                                                                                scheduleRelative: (
                                                                                                                                                                                                                                                                                                                                                                                                state: any,
                                                                                                                                                                                                                                                                                                                                                                                                dueTime: number,
                                                                                                                                                                                                                                                                                                                                                                                                action: (scheduler: IScheduler, state: any) => IDisposable
                                                                                                                                                                                                                                                                                                                                                                                                ) => IDisposable,
                                                                                                                                                                                                                                                                                                                                                                                                scheduleAbsolute: (
                                                                                                                                                                                                                                                                                                                                                                                                state: any,
                                                                                                                                                                                                                                                                                                                                                                                                dueTime: number,
                                                                                                                                                                                                                                                                                                                                                                                                action: (scheduler: IScheduler, state: any) => IDisposable
                                                                                                                                                                                                                                                                                                                                                                                                ) => IDisposable
                                                                                                                                                                                                                                                                                                                                                                                                ): Scheduler;

                                                                                                                                                                                                                                                                                                                                                                                                  interface TimeInterval

                                                                                                                                                                                                                                                                                                                                                                                                  interface TimeInterval<T> {}

                                                                                                                                                                                                                                                                                                                                                                                                    property interval

                                                                                                                                                                                                                                                                                                                                                                                                    interval: number;

                                                                                                                                                                                                                                                                                                                                                                                                      property value

                                                                                                                                                                                                                                                                                                                                                                                                      value: T;

                                                                                                                                                                                                                                                                                                                                                                                                        interface Timestamp

                                                                                                                                                                                                                                                                                                                                                                                                        interface Timestamp<T> {}

                                                                                                                                                                                                                                                                                                                                                                                                          property timestamp

                                                                                                                                                                                                                                                                                                                                                                                                          timestamp: number;

                                                                                                                                                                                                                                                                                                                                                                                                            property value

                                                                                                                                                                                                                                                                                                                                                                                                            value: T;

                                                                                                                                                                                                                                                                                                                                                                                                              namespace rx-lite

                                                                                                                                                                                                                                                                                                                                                                                                              module 'rx-lite' {}

                                                                                                                                                                                                                                                                                                                                                                                                                variable Observable

                                                                                                                                                                                                                                                                                                                                                                                                                const Observable: ObservableStatic;

                                                                                                                                                                                                                                                                                                                                                                                                                  variable Observer

                                                                                                                                                                                                                                                                                                                                                                                                                  const Observer: ObserverStatic;

                                                                                                                                                                                                                                                                                                                                                                                                                    variable Scheduler

                                                                                                                                                                                                                                                                                                                                                                                                                    const Scheduler: SchedulerStatic;

                                                                                                                                                                                                                                                                                                                                                                                                                      class CompositeDisposable

                                                                                                                                                                                                                                                                                                                                                                                                                      class CompositeDisposable implements IDisposable {}

                                                                                                                                                                                                                                                                                                                                                                                                                        constructor

                                                                                                                                                                                                                                                                                                                                                                                                                        constructor(...disposables: IDisposable[]);

                                                                                                                                                                                                                                                                                                                                                                                                                          constructor

                                                                                                                                                                                                                                                                                                                                                                                                                          constructor(disposables: IDisposable[]);

                                                                                                                                                                                                                                                                                                                                                                                                                            property isDisposed

                                                                                                                                                                                                                                                                                                                                                                                                                            isDisposed: boolean;

                                                                                                                                                                                                                                                                                                                                                                                                                              property length

                                                                                                                                                                                                                                                                                                                                                                                                                              length: number;

                                                                                                                                                                                                                                                                                                                                                                                                                                method add

                                                                                                                                                                                                                                                                                                                                                                                                                                add: (item: IDisposable) => void;

                                                                                                                                                                                                                                                                                                                                                                                                                                  method dispose

                                                                                                                                                                                                                                                                                                                                                                                                                                  dispose: () => void;

                                                                                                                                                                                                                                                                                                                                                                                                                                    method remove

                                                                                                                                                                                                                                                                                                                                                                                                                                    remove: (item: IDisposable) => boolean;

                                                                                                                                                                                                                                                                                                                                                                                                                                      method toArray

                                                                                                                                                                                                                                                                                                                                                                                                                                      toArray: () => IDisposable[];

                                                                                                                                                                                                                                                                                                                                                                                                                                        class Disposable

                                                                                                                                                                                                                                                                                                                                                                                                                                        class Disposable implements IDisposable {}

                                                                                                                                                                                                                                                                                                                                                                                                                                          constructor

                                                                                                                                                                                                                                                                                                                                                                                                                                          constructor(action: () => void);

                                                                                                                                                                                                                                                                                                                                                                                                                                            property empty

                                                                                                                                                                                                                                                                                                                                                                                                                                            static empty: IDisposable;

                                                                                                                                                                                                                                                                                                                                                                                                                                              method create

                                                                                                                                                                                                                                                                                                                                                                                                                                              static create: (action: () => void) => IDisposable;

                                                                                                                                                                                                                                                                                                                                                                                                                                                method dispose

                                                                                                                                                                                                                                                                                                                                                                                                                                                dispose: () => void;

                                                                                                                                                                                                                                                                                                                                                                                                                                                  class Notification

                                                                                                                                                                                                                                                                                                                                                                                                                                                  class Notification<T> {}

                                                                                                                                                                                                                                                                                                                                                                                                                                                    property exception

                                                                                                                                                                                                                                                                                                                                                                                                                                                    exception: any;

                                                                                                                                                                                                                                                                                                                                                                                                                                                      property hasValue

                                                                                                                                                                                                                                                                                                                                                                                                                                                      hasValue: boolean;

                                                                                                                                                                                                                                                                                                                                                                                                                                                        property kind

                                                                                                                                                                                                                                                                                                                                                                                                                                                        kind: string;

                                                                                                                                                                                                                                                                                                                                                                                                                                                          property value

                                                                                                                                                                                                                                                                                                                                                                                                                                                          value: {};

                                                                                                                                                                                                                                                                                                                                                                                                                                                            method accept

                                                                                                                                                                                                                                                                                                                                                                                                                                                            accept: {
                                                                                                                                                                                                                                                                                                                                                                                                                                                            (observer: IObserver<T>): void;
                                                                                                                                                                                                                                                                                                                                                                                                                                                            <TResult>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                            onNext: (value: T) => TResult,
                                                                                                                                                                                                                                                                                                                                                                                                                                                            onError?: (exception: any) => TResult,
                                                                                                                                                                                                                                                                                                                                                                                                                                                            onCompleted?: () => TResult
                                                                                                                                                                                                                                                                                                                                                                                                                                                            ): TResult;
                                                                                                                                                                                                                                                                                                                                                                                                                                                            };

                                                                                                                                                                                                                                                                                                                                                                                                                                                              method createOnCompleted

                                                                                                                                                                                                                                                                                                                                                                                                                                                              static createOnCompleted: <T>() => Notification<T>;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                method createOnError

                                                                                                                                                                                                                                                                                                                                                                                                                                                                static createOnError: <T>(exception: any) => Notification<T>;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                  method createOnNext

                                                                                                                                                                                                                                                                                                                                                                                                                                                                  static createOnNext: <T>(value: T) => Notification<T>;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                    method equals

                                                                                                                                                                                                                                                                                                                                                                                                                                                                    equals: (other: Notification<T>) => boolean;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                      method toObservable

                                                                                                                                                                                                                                                                                                                                                                                                                                                                      toObservable: (scheduler?: IScheduler) => Observable<T>;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                        class RefCountDisposable

                                                                                                                                                                                                                                                                                                                                                                                                                                                                        class RefCountDisposable implements IDisposable {}

                                                                                                                                                                                                                                                                                                                                                                                                                                                                          constructor

                                                                                                                                                                                                                                                                                                                                                                                                                                                                          constructor(disposable: IDisposable);

                                                                                                                                                                                                                                                                                                                                                                                                                                                                            property isDisposed

                                                                                                                                                                                                                                                                                                                                                                                                                                                                            isDisposed: boolean;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                              method dispose

                                                                                                                                                                                                                                                                                                                                                                                                                                                                              dispose: () => void;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                method getDisposable

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                getDisposable: () => IDisposable;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  class SerialDisposable

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  class SerialDisposable extends SingleAssignmentDisposable {}

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    constructor

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    constructor();

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      class SingleAssignmentDisposable

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      class SingleAssignmentDisposable implements IDisposable {}

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        constructor

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        constructor();

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          property current

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          current: IDisposable;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            property isDisposed

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            isDisposed: boolean;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              method dispose

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              dispose: () => void;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                method getDisposable

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                getDisposable: () => IDisposable;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  method setDisposable

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  setDisposable: (value: IDisposable) => void;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    interface ConnectableObservable

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    interface ConnectableObservable<T> extends Observable<T> {}

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      method connect

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      connect: () => Disposable;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        interface DOMEventTarget

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        interface DOMEventTarget {}

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          method addEventListener

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          addEventListener: (
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          type: string,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          listener: (e: any) => any,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          useCapture: boolean
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          ) => void;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            method removeEventListener

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            removeEventListener: (
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            type: string,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            listener: (e: any) => any,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            useCapture: boolean
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            ) => void;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              interface ICurrentThreadScheduler

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              interface ICurrentThreadScheduler extends IScheduler {}

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                method scheduleRequired

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                scheduleRequired: () => boolean;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  interface IObservable

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  interface IObservable<T> {}

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    method subscribe

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    subscribe: {
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    (observer: Observer<T>): IDisposable;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    (
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    onNext?: (value: T) => void,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    onError?: (exception: any) => void,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    onCompleted?: () => void
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    ): IDisposable;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    };

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      method subscribeOnCompleted

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      subscribeOnCompleted: (onCompleted: () => void, thisArg?: any) => IDisposable;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        method subscribeOnError

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        subscribeOnError: (
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        onError: (exception: any) => void,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        thisArg?: any
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        ) => IDisposable;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          method subscribeOnNext

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          subscribeOnNext: (onNext: (value: T) => void, thisArg?: any) => IDisposable;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            interface IObserver

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            interface IObserver<T> {}

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              method onCompleted

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              onCompleted: () => void;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                method onError

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                onError: (exception: any) => void;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  method onNext

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  onNext: (value: T) => void;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    interface IScheduler

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    interface IScheduler {}

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      method isScheduler

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      isScheduler: (value: any) => boolean;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        method now

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        now: () => number;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          method schedule

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          schedule: (action: () => void) => IDisposable;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            method schedulePeriodic

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            schedulePeriodic: (period: number, action: () => void) => IDisposable;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              method schedulePeriodicWithState

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              schedulePeriodicWithState: <TState>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              state: TState,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              period: number,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              action: (state: TState) => TState
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              ) => IDisposable;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                method scheduleRecursive

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                scheduleRecursive: (action: (action: () => void) => void) => IDisposable;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  method scheduleRecursiveWithAbsolute

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  scheduleRecursiveWithAbsolute: (
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  dueTime: number,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  action: (action: (dueTime: number) => void) => void
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  ) => IDisposable;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    method scheduleRecursiveWithAbsoluteAndState

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    scheduleRecursiveWithAbsoluteAndState: <TState>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    state: TState,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    dueTime: number,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    action: (
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    state: TState,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    action: (state: TState, dueTime: number) => void
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    ) => void
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    ) => IDisposable;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      method scheduleRecursiveWithRelative

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      scheduleRecursiveWithRelative: (
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      dueTime: number,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      action: (action: (dueTime: number) => void) => void
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      ) => IDisposable;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        method scheduleRecursiveWithRelativeAndState

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        scheduleRecursiveWithRelativeAndState: <TState>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        state: TState,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        dueTime: number,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        action: (
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        state: TState,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        action: (state: TState, dueTime: number) => void
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        ) => void
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        ) => IDisposable;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          method scheduleRecursiveWithState

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          scheduleRecursiveWithState: <TState>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          state: TState,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          action: (state: TState, action: (state: TState) => void) => void
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          ) => IDisposable;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            method scheduleWithAbsolute

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            scheduleWithAbsolute: (dueTime: number, action: () => void) => IDisposable;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              method scheduleWithAbsoluteAndState

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              scheduleWithAbsoluteAndState: <TState>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              state: TState,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              dueTime: number,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              action: (scheduler: IScheduler, state: TState) => IDisposable
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              ) => IDisposable;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                method scheduleWithRelative

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                scheduleWithRelative: (dueTime: number, action: () => void) => IDisposable;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  method scheduleWithRelativeAndState

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  scheduleWithRelativeAndState: <TState>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  state: TState,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  dueTime: number,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  action: (scheduler: IScheduler, state: TState) => IDisposable
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  ) => IDisposable;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    method scheduleWithState

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    scheduleWithState: <TState>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    state: TState,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    action: (scheduler: IScheduler, state: TState) => IDisposable
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    ) => IDisposable;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      interface NativeEventTarget

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      interface NativeEventTarget {}

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        method off

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        off: (name: string, cb: (e: any) => any) => void;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          method on

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          on: (name: string, cb: (e: any) => any) => void;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            interface NodeEventTarget

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            interface NodeEventTarget {}

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              method addListener

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              addListener: (name: string, cb: (e: any) => any) => void;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                interface Observable

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                interface Observable<T> extends IObservable<T> {}

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  method asObservable

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  asObservable: () => Observable<T>;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    method catch

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    catch: {
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    (handler: (exception: Error) => IPromise<T> | Observable<T>): Observable<T>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    (second: Observable<T>): Observable<T>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    };

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      method catchException

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      catchException: {
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      (handler: (exception: Error) => IPromise<T> | Observable<T>): Observable<T>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      (second: Observable<T>): Observable<T>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      };

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        method combineLatest

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        combineLatest: {
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        <T2>(second: Observable<T2> | IPromise<T2>): Observable<[T, T2]>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        <T2, TResult>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        second: any,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        resultSelector: (v1: T, v2: T2) => TResult
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        ): Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        <T2, T3>(second: any, third: any): Observable<[T, T2, T3]>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        <T2, T3, TResult>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        second: any,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        third: any,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        resultSelector: (v1: T, v2: T2, v3: T3) => TResult
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        ): Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        <T2, T3, T4>(second: any, third: any, fourth: any): Observable<
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        [T, T2, T3, T4]
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        >;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        <T2, T3, T4, TResult>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        second: any,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        third: any,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        fourth: any,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        resultSelector: (v1: T, v2: T2, v3: T3, v4: T4) => TResult
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        ): Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        <T2, T3, T4, T5>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        second: any,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        third: any,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        fourth: any,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        fifth: any
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        ): Observable<[T, T2, T3, T4, T5]>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        <T2, T3, T4, T5, TResult>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        second: any,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        third: any,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        fourth: any,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        fifth: any,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        resultSelector: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        ): Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        <TOther, TResult>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        souces: any[],
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        resultSelector: (firstValue: T, ...otherValues: TOther[]) => TResult
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        ): Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        };

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          method concat

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          concat: {
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          (...sources: (Observable<T> | IPromise<T>)[]): Observable<T>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          (sources: any[]): Observable<T>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          };

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            method concatAll

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            concatAll: () => T;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              method concatMap

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              concatMap: {
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              <T2, R>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              selector: (value: T, index: number) => Observable<T2>,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              resultSelector: (value1: T, value2: T2, index: number) => R
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              ): Observable<R>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              <T2, R>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              selector: (value: T, index: number) => IPromise<T2>,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              resultSelector: (value1: T, value2: T2, index: number) => R
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              ): Observable<R>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              <R>(selector: (value: T, index: number) => Observable<R>): Observable<R>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              <R>(selector: (value: T, index: number) => IPromise<R>): Observable<R>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              <R>(selector: (value: T, index: number) => R[]): Observable<R>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              <R>(sequence: Observable<R>): Observable<R>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              <R>(sequence: R[]): Observable<R>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              };

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                method concatObservable

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                concatObservable: () => Observable<T>;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  method dematerialize

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  dematerialize: <TOrigin>() => Observable<TOrigin>;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    method distinctUntilChanged

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    distinctUntilChanged: {
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    (skipParameter: boolean, comparer: (x: T, y: T) => boolean): Observable<T>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    <TValue>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    keySelector?: (value: T) => TValue,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    comparer?: (x: TValue, y: TValue) => boolean
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    ): Observable<T>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    };

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      method do

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      do: {
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      (observer: Observer<T>): Observable<T>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      (
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      onNext?: (value: T) => void,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      onError?: (exception: Error) => void,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      onCompleted?: () => void
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      ): Observable<T>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      };

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        method doAction

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        doAction: {
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        (observer: Observer<T>): Observable<T>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        (
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        onNext?: (value: T) => void,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        onError?: (exception: Error) => void,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        onCompleted?: () => void
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        ): Observable<T>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        };

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          method doOnCompleted

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          doOnCompleted: (onCompleted: () => void, thisArg?: any) => Observable<T>;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            method doOnError

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            doOnError: (onError: (exception: any) => void, thisArg?: any) => Observable<T>;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              method doOnNext

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              doOnNext: (onNext: (value: T) => void, thisArg?: any) => Observable<T>;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                method exclusive

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                exclusive: <R>() => Observable<R>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                • Performs a exclusive waiting for the first to finish before subscribing to another observable. Observables that come in between subscriptions will be dropped on the floor. Can be applied on Observable<Observable<R>> or Observable<IPromise<R>>. 2.2.28

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  Returns

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  A exclusive observable with only the results that happen when subscribed.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                method exclusiveMap

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                exclusiveMap: <I, R>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                selector: (value: I, index: number, source: Observable<I>) => R,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                thisArg?: any
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                ) => Observable<R>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                • Performs a exclusive map waiting for the first to finish before subscribing to another observable. Observables that come in between subscriptions will be dropped on the floor. Can be applied on Observable<Observable<I>> or Observable<IPromise<I>>. 2.2.28

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  Parameter selector

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  Selector to invoke for every item in the current subscription.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  Parameter thisArg

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  An optional context to invoke with the selector parameter.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  Returns

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  An exclusive observable with only the results that happen when subscribed.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                method filter

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                filter: (
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                predicate: (value: T, index: number, source: Observable<T>) => boolean,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                thisArg?: any
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                ) => Observable<T>;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  method finally

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  finally: (action: () => void) => Observable<T>;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    method finallyAction

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    finallyAction: (action: () => void) => Observable<T>;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      method flatMap

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      flatMap: {
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      <TOther, TResult>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      selector: (value: T) => Observable<TOther>,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      resultSelector: (item: T, other: TOther) => TResult
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      ): Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      <TOther, TResult>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      selector: (value: T) => IPromise<TOther>,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      resultSelector: (item: T, other: TOther) => TResult
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      ): Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      <TResult>(selector: (value: T) => Observable<TResult>): Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      <TResult>(selector: (value: T) => IPromise<TResult>): Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      <TResult>(other: Observable<TResult>): Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      <TResult>(other: IPromise<TResult>): Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      <TResult>(selector: (value: T) => TResult[]): Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      };

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        method flatMapLatest

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        flatMapLatest: <TResult>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        selector: (
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        value: T,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        index: number,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        source: Observable<T>
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        ) => Observable<TResult>,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        thisArg?: any
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        ) => Observable<TResult>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        • 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.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          Parameter selector

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          A transform function to apply to each source element; the second parameter of the function represents the index of the source element.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          Parameter thisArg

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          Object to use as this when executing callback.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          Returns

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          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.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        method flatMapObserver

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        flatMapObserver: <T2, T3, T4>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        onNext: (value: T, index: number) => Observable<T2>,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        onError: (exception: any) => Observable<T3>,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        onCompleted: () => Observable<T4>,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        thisArg?: any
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        ) => Observable<T2 | T3 | T4>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        • Projects each notification of an observable sequence to an observable sequence and merges the resulting observable sequences into one observable sequence.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          Parameter onNext

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          A transform function to apply to each element; the second parameter of the function represents the index of the source element.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          Parameter onError

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          A transform function to apply when an error occurs in the source sequence.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          Parameter onCompleted

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          A transform function to apply when the end of the source sequence is reached.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          Parameter thisArg

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          An optional "this" to use to invoke each transform.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          Returns

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          An observable sequence whose elements are the result of invoking the one-to-many transform function corresponding to each notification in the input sequence.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        method forEach

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        forEach: (
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        onNext?: (value: T) => void,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        onError?: (exception: any) => void,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        onCompleted?: () => void
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        ) => IDisposable;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          method ignoreElements

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          ignoreElements: () => Observable<T>;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            method map

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            map: <TResult>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            selector: (value: T, index: number, source: Observable<T>) => TResult,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            thisArg?: any
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            ) => Observable<TResult>;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              method materialize

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              materialize: () => Observable<Notification<T>>;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                method merge

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                merge: {
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                (maxConcurrent: number): T;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                (other: Observable<T>): Observable<T>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                (other: IPromise<T>): Observable<T>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                };

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  method mergeAll

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  mergeAll: () => T;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    method mergeObservable

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    mergeObservable: () => T;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      method pluck

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      pluck: <TResult>(prop: string) => Observable<TResult>;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        method publish

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        publish: () => ConnectableObservable<T>;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          method repeat

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          repeat: (repeatCount?: number) => Observable<T>;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            method retry

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            retry: (retryCount?: number) => Observable<T>;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              method retryWhen

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              retryWhen: <TError>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              notifier: (errors: Observable<TError>) => Observable<any>
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                              ) => Observable<T>;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                method scan

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                scan: {
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                <TAcc>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                accumulator: (
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                acc: TAcc,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                value: T,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                index?: number,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                source?: Observable<TAcc>
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                ) => TAcc,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                seed: TAcc
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                ): Observable<TAcc>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                (
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                accumulator: (
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                acc: T,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                value: T,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                index?: number,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                source?: Observable<T>
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                ) => T
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                ): Observable<T>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                };
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                • Applies an accumulator function over an observable sequence and returns each intermediate result. The optional seed value is used as the initial accumulator value. For aggregation behavior with no intermediate results, see Observable.aggregate.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  Parameter accumulator

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  An accumulator function to be invoked on each element.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  Parameter seed

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  The initial accumulator value.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  Returns

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  An observable sequence containing the accumulated values.

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  Example 1

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  var res = source.scan(function (acc, x) { return acc + x; }); var res = source.scan(function (acc, x) { return acc + x; }, 0);

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                method select

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                select: <TResult>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                selector: (value: T, index: number, source: Observable<T>) => TResult,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                thisArg?: any
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                ) => Observable<TResult>;

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  method selectConcat

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  selectConcat: {
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  <T2, R>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  selector: (value: T, index: number) => Observable<T2>,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  resultSelector: (value1: T, value2: T2, index: number) => R
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  ): Observable<R>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  <T2, R>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  selector: (value: T, index: number) => IPromise<T2>,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  resultSelector: (value1: T, value2: T2, index: number) => R
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  ): Observable<R>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  <R>(selector: (value: T, index: number) => Observable<R>): Observable<R>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  <R>(selector: (value: T, index: number) => IPromise<R>): Observable<R>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  <R>(sequence: Observable<R>): Observable<R>;
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  };

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    method selectMany

                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    selectMany: {
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    <TOther, TResult>(
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    selector