Subscriber

Implementa el interfaz Observador y extiende la clase Suscripción. Mientras el Observador es la API pública para consumir los valores de un Observable, todos los Observadores se convierten en Suscriptores, para poder proporcionar capacidades propias de la Suscripción, tal y como unsubscribe. Subscriber es un tipo común en RxJS y es crucial para implementar operadores, pero raramente se utiliza como API pública

class Subscriber<T> extends Subscription implements Observer {
static create<T>(next?: (x?: T) => void, error?: (e?: any) => void, complete?: () => void): Subscriber<T>
constructor(destinationOrNext?: NextObserver<any> | ErrorObserver<any> | CompletionObserver<any> | ((value: T) => void), error?: (e?: any) => void, complete?: () => void)
protected isStopped: boolean
protected destination: PartialObserver<any> | Subscriber<any>
next(value?: T): void
error(err?: any): void
complete(): void
unsubscribe(): void
protected _next(value: T): void
protected _error(err: any): void
protected _complete(): void
_unsubscribeAndRecycle(): Subscriber<T>

// Heredado de index/Subscription
static EMPTY: Subscription
constructor(unsubscribe?: () => void)
closed: [object Object]
unsubscribe(): void
add(teardown: TeardownLogic): Subscription
remove(subscription: Subscription): void
}

Métodos Estáticos

create()
Una factoría estática para un Suscriptor, dada una (posiblemente parcial) definición de un Observador.
Firma static create(next?: (x?: T) => void, error?: (e?: any) => void, complete?: () => void): Subscriber Parámetros next Opcional. El valor por defecto es undefined. La callback next de un Observador. error Opcional. El valor por defecto es undefined. La callback error de un Observador. complete Opcional. El valor por defecto es undefined. La callback de un Observador. Retorna Subscriber: Un Suscriptor que envuelve el Observador (parcialmente definido) representado por los argumentos dados.

Constructor

constructor()

Firma constructor(destinationOrNext?: NextObserver | ErrorObserver | CompletionObserver | ((value: T) => void), error?: (e?: any) => void, complete?: () => void) Parámetros destinationOrNext Opcional. El valor por defecto es undefined. Un Observador parcialmente definido o una función callback next. error Opcional. El valor por defecto es undefined. La callback error de un Observador. complete Opcional. El valor por defecto es undefined. La callback complete de un Observador.

Propiedades

Propiedad	Tipo	Descripción
isStopped	boolean
destination	PartialObserver | Subscriber

Métodos

next()
La callback Observador para recibir notificaciones de tipo next del Observable, con un valor. El Observable puede llamar a este método 0 o más veces.
Firma next(value?: T): void Parámetros value Opcional. El valor por defecto es undefined. El valor next. Retorna void:

error()
La callback Observador para recibir notificaciones de tipo error del Observable, con un error adjunto. Notifica al Observador que el Observable ha experimentado una condición de error.
Firma error(err?: any): void Parámetros err Opcional. El valor por defecto es undefined. La excepción error. Retorna void:

complete()
La callback Observador para recibir una notificación sin valor de tipo complete del Observable. Notifica al Observador que el Observable ha terminado de emitir notificaciones push
Firma complete(): void Parámetros No recibe ningún parámetro. Retorna void:

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

_next()
Firma protected _next(value: T): void Parámetros value Tipo: T. Retorna void

_error()
Firma protected _error(err: any): void Parámetros err Tipo: any. Retorna void

_complete()
Firma protected _complete(): void Parámetros No recibe ningún parámetro. Retorna void

_unsubscribeAndRecycle()
Firma _unsubscribeAndRecycle(): Subscriber Parámetros No recibe ningún parámetro. Retorna Subscriber

Recursos adicionales

Documentación oficial en inglés