An observable with a connect method that is used to create a subscription to an underlying source, connecting it with all consumers via a multicast.

interface Connectable<T> extends Observable<T> {
  connect(): Subscription

  // 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>
}

Methods

connect(): Subscription

(Idempotent) Calling this method will connect the underlying source observable to all subscribed consumers through an underlying Subject.

Parameters

There are no parameters.

Returns

Subscription: A subscription, that when unsubscribed, will "disconnect" the source from the connector subject, severing notifications to all consumers.