Subject

Un Sujeto es un tipo especial de Observable que permite que los valores sean multidifundidos a varios Observadores. Los Sujetos son como EventEmitters

class Subject<T> extends Observable implements SubscriptionLike {
  static create: Function;
  constructor();
  observers: Observer<T>[];
  closed: false;
  isStopped: false;
  hasError: false;
  thrownError: any;
  lift<R>(operator: Operator<T, R>): Observable<R>;
  next(value?: T);
  error(err: any);
  complete();
  unsubscribe();
  _trySubscribe(subscriber: Subscriber<T>): TeardownLogic;
  _subscribe(subscriber: Subscriber<T>): Subscription;
  asObservable(): 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>;
}

Subclases

• BehaviorSubject

• ReplaySubject

• AsyncSubject

Descripción

Cada Sujeto es un Observable y un Observador. Se puede realizar una suscripción a un Sujeto, y llamar al método next() para proporcionarle valores, además de notificaciones de error y complete.

Propiedades Estáticas

Property	Type	Description
create	Function

Constructor

constructor()
constructor() Parámetros No recibe ningún parámetro.

Propiedades

Propiedad	Tipo	Descripción
observers	Observer[]
closed	false
isStopped	false
hasError	false
thrownError	any

Métodos

lift()
Firma lift(operator: Operator): Observable Parámetros Retorna Observable
operator	Tipo: Operator.

next()
Firma next(value?: T) Parámetros
value	Opcional. El valor por defecto es undefined. Tipo: T.

error()
Firma error(err: any) Parámetros
err	Tipo: any.

complete()
Firma complete() Parámetros No recibe ningún parámetro.

unsubscribe()
Firma unsubscribe() Parámetros No recibe ningún parámetro.

_trySubscribe()
Firma _trySubscribe(subscriber: Subscriber): TeardownLogic Parámetros Retorna TeardownLogic
subscriber	Tipo: Subscriber.

_subscribe()
Firma _subscribe(subscriber: Subscriber): Subscription Parámetros Retorna Subscription
subscriber	Tipo: Subscriber.

asObservable()
Crea un nuevo Observable con este Sujeto como fuente. Se puede hacer esto para crear lógica personalizada de la parte Observador del Sujeto y esconderla del código que utiliza el Observable
Firma asObservable(): Observable Parámetros No recibe ningún parámetro. Retorna Observable: Observable that the Subject casts to