ConnectableObservable

class ConnectableObservable<T> extends Observable {
  constructor(source: Observable<T>, subjectFactory: () => Subject<T>);
  protected _subject: Subject<T>;
  protected _refCount: number;
  protected _connection: Subscription;
  source: Observable<T>;
  protected subjectFactory: () => Subject<T>;
  _subscribe(subscriber: Subscriber<T>);
  protected getSubject(): Subject<T>;
  connect(): Subscription;
  refCount(): Observable<T>;

  // Heredado de index/Observable
  static create: Function;
  static if: typeof iif;
  static throw: typeof throwError;
  constructor(
    subscribe?: (
      this: Observable<T>,
      subscriber: Subscriber<T>
    ) => TeardownLogic
  );
  _isScalar: boolean;
  source: Observable<any>;
  operator: Operator<any, T>;
  lift<R>(operator: Operator<T, R>): Observable<R>;
  subscribe(
    observerOrNext?:
      | NextObserver<T>
      | ErrorObserver<T>
      | CompletionObserver<T>
      | ((value: T) => void),
    error?: (error: any) => void,
    complete?: () => void
  ): Subscription;
  _trySubscribe(sink: Subscriber<T>): TeardownLogic;
  forEach(
    next: (value: T) => void,
    promiseCtor?: PromiseConstructorLike
  ): Promise<void>;
  pipe(...operations: OperatorFunction<any, any>[]): Observable<any>;
  toPromise(promiseCtor?: PromiseConstructorLike): Promise<T>;
}

Constructor

constructor()

Firma

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

Parámetros

source

Tipo: Observable.

subjectFactory

Tipo: () => Subject.

Propiedades

PropiedadTipoDescripción

_subject

Subject

_refCount

number

_connection

Subscription

source

Observable

Declarado en el constructor.

subjectFactory

() => Subject

Declarado en el constructor.

Métodos

_subscribe()

Firma

_subscribe(subscriber: Subscriber)

Parámetros

subscriber

Tipo: Subscriber.

getSubject()

Firma

protected getSubject(): Subject

Parámetros

No recibe ningún parámetro.

Retorna

Subject

connect()

Firma

connect(): Subscription

Parámetros

No recibe ningún parámetro.

Retorna

Subscription

refCount()

Firma

refCount(): Observable

Parámetros

No recibe ningún parámetro.

Retorna

Observable

Last updated