Options
All
  • Public
  • Public/Protected
  • All
Menu

Type Parameters

  • T

Hierarchy

  • Observable<T>
    • Concast

Index

Constructors

Properties

cancel: ((reason: any) => void)

Type declaration

    • (reason: any): void
    • Parameters

      • reason: any

      Returns void

deliverLastMessage: any
handlers: any
latest?: any
nextResultListeners: any
notify: any
observers: any
promise: internal.Promise<T>
reject: any
resolve: any
sources: any
start: any
sub?: any

Methods

  • [observable](): Observable<T>
  • Returns Observable<T>

  • addObserver(observer: Observer<T>): void
  • Parameters

    Returns void

  • Parameters

    Returns void

  • concat<R>(...observable: Observable<R>[]): Observable<R>
  • Type Parameters

    • R

    Parameters

    • Rest ...observable: Observable<R>[]

    Returns Observable<R>

  • filter<S>(callback: ((value: T) => value is S)): Observable<S>
  • filter(callback: ((value: T) => boolean)): Observable<T>
  • Type Parameters

    • S

    Parameters

    • callback: ((value: T) => value is S)
        • (value: T): value is S
        • Parameters

          • value: T

          Returns value is S

    Returns Observable<S>

  • Parameters

    • callback: ((value: T) => boolean)
        • (value: T): boolean
        • Parameters

          • value: T

          Returns boolean

    Returns Observable<T>

  • flatMap<R>(callback: ((value: T) => ObservableLike<R>)): Observable<R>
  • Type Parameters

    • R

    Parameters

    Returns Observable<R>

  • Parameters

    • callback: ((value: T) => void)
        • (value: T): void
        • Parameters

          • value: T

          Returns void

    Returns internal.Promise<void>

  • map<R>(callback: ((value: T) => R)): Observable<R>
  • Type Parameters

    • R

    Parameters

    • callback: ((value: T) => R)
        • (value: T): R
        • Parameters

          • value: T

          Returns R

    Returns Observable<R>

  • reduce(callback: ((previousValue: T, currentValue: T) => T), initialValue?: T): Observable<T>
  • reduce<R>(callback: ((previousValue: R, currentValue: T) => R), initialValue?: R): Observable<R>
  • Parameters

    • callback: ((previousValue: T, currentValue: T) => T)
        • (previousValue: T, currentValue: T): T
        • Parameters

          • previousValue: T
          • currentValue: T

          Returns T

    • Optional initialValue: T

    Returns Observable<T>

  • Type Parameters

    • R

    Parameters

    • callback: ((previousValue: R, currentValue: T) => R)
        • (previousValue: R, currentValue: T): R
        • Parameters

          • previousValue: R
          • currentValue: T

          Returns R

    • Optional initialValue: R

    Returns Observable<R>

  • removeObserver(observer: Observer<T>): void
  • Parameters

    Returns void

  • subscribe(observer: Observer<T>): Subscription
  • subscribe(onNext: ((value: T) => void), onError?: ((error: any) => void), onComplete?: (() => void)): Subscription
  • Parameters

    Returns Subscription

  • Parameters

    • onNext: ((value: T) => void)
        • (value: T): void
        • Parameters

          • value: T

          Returns void

    • Optional onError: ((error: any) => void)
        • (error: any): void
        • Parameters

          • error: any

          Returns void

    • Optional onComplete: (() => void)
        • (): void
        • Returns void

    Returns Subscription

  • Type Parameters

    • R

    Parameters

    Returns undefined

  • call<R>(instance: Observable<R>, subscriber: Subscriber<R>): undefined
  • Type Parameters

    • R

    Parameters

    Returns undefined

  • Type Parameters

    • R

    Parameters

    Returns Observable<R>

  • of<R>(...items: R[]): Observable<R>
  • Type Parameters

    • R

    Parameters

    • Rest ...items: R[]

    Returns Observable<R>

Generated using TypeDoc