> For the complete documentation index, see [llms.txt](https://www.rxjs.es/llms.txt). Markdown versions of documentation pages are available by appending `.md` to page URLs; this page is available as [Markdown](https://www.rxjs.es/api/indice/subscriber.md). # 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 ```typescript class Subscriber extends Subscription implements Observer { static create(next?: (x?: T) => void, error?: (e?: any) => void, complete?: () => void): Subscriber constructor(destinationOrNext?: NextObserver | ErrorObserver | CompletionObserver | ((value: T) => void), error?: (e?: any) => void, complete?: () => void) protected isStopped: boolean protected destination: PartialObserver | Subscriber 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 // 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. | | 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. | | | | | 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. | | 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. | | 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`. | | value | Tipo: `T`. | | ----- | ---------- | | \_error() | | | ------------------------------------------------------------------------------------------------------------------------------ | ------------ | |

Firma

protected \_error(err: any): void

Parámetros

Retorna

void

| | | err | Tipo: `any`. | | 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 [![Source code](https://github.com/puntotech/rxjs-docu/blob/master/doc/api/index/assets/icons/source-code.png)](https://github.com/ReactiveX/rxjs/blob/6.5.5/src/internal/Subscriber.ts#L8-L162) [Documentación oficial en inglés](https://rxjs.dev/api/index/class/Subscriber)