Options
All
  • Public
  • Public/Protected
  • All
Menu

Class ProxyObservable<T>

Special flavor of an Observable that is undying, in that when the source completes or errors, this instance's stream will persist and wait for a new source to be set.

This allows us to hot-swap input and output streams without needing to manually recover other subscribers to this instance.

Type parameters

  • T

Hierarchy

  • ProxyObservable

Implements

Index

Constructors

Properties

Methods

Constructors

constructor

Properties

Readonly onComplete

onComplete: Observable<any> = ...

Protected Readonly onCompleteSubject

onCompleteSubject: Subject<any> = ...

Readonly onError

onError: Observable<T> = ...

Protected Readonly onErrorSubject

onErrorSubject: Subject<T> = ...

Readonly onNext

onNext: Observable<T> = ...

Protected Readonly onNextSubject

onNextSubject: Subject<T> = ...

Methods

asObservable

  • asObservable(): Observable<T>

clearSource

  • clearSource(): void

destroy

  • destroy(errorMessage?: string): void

isDestroyed

  • isDestroyed(): boolean

setSource

  • setSource(source: Subscribable<T>): void

Generated using TypeDoc