ConnectableObservable

Deprecation Notes

Will be removed in v8. Use connectable to create a connectable observable. If you are using the refCount method of ConnectableObservable, use the share operator instead. Details: https://rxjs.dev/deprecations/multicasting

class ConnectableObservable<T> extends Observable {
  constructor(source: Observable<T>, subjectFactory: () => Subject<T>)
  protected _subject: Subject<T> | null
  protected _refCount: number
  protected _connection: Subscription | null
  source: Observable<T>
  protected subjectFactory: () => Subject<T>
  protected getSubject(): Subject<T>
  protected _teardown()
  connect(): Subscription
  refCount(): Observable<T>

  // inherited from index/Observable
  static create: (...args: any[]) => any
  constructor(subscribe?: (this: Observable<T>, subscriber: Subscriber<T>) => TeardownLogic)
  source: Observable<any> | undefined
  operator: Operator<any, T> | undefined
  lift<R>(operator?: Operator<T, R>): Observable<R>
  subscribe(observerOrNext?: Partial<Observer<T>> | ((value: T) => void), error?: (error: any) => void, complete?: () => void): Subscription
  forEach(next: (value: T) => void, promiseCtor?: PromiseConstructorLike): Promise<void>
  pipe(...operations: OperatorFunction<any, any>[]): Observable<any>
  toPromise(promiseCtor?: PromiseConstructorLike): Promise<T | undefined>
}

Constructor

constructor(source: Observable<T>, subjectFactory: () => Subject<T>)

Parameters

source	The source observable
subjectFactory	The factory that creates the subject used internally.

Properties

Property	Type	Description
_subject	Subject<T> | null
_refCount	number
_connection	Subscription | null
source	Observable<T>	The source observable Declared in constructor.
subjectFactory	() => Subject<T>	The factory that creates the subject used internally. Declared in constructor.

Methods

protected getSubject(): Subject<T>

Parameters

There are no parameters.

Returns

Subject<T>

protected _teardown()

Parameters

There are no parameters.

connect(): Subscription

Parameters

There are no parameters.

Returns

Subscription

refCount(): Observable<T>

Parameters

There are no parameters.

Returns

Observable<T>