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 Retorna Subscriber: Un Suscriptor que envuelve el Observador (parcialmente definido) representado por los argumentos dados.
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.

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 Retorna void:
value	Opcional. El valor por defecto es undefined. El valor next.

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 Retorna void:
err	Opcional. El valor por defecto es undefined. La excepción error.

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 Retorna void
value	Tipo: T.

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

_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