# 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) --- # Agent Instructions: Querying This Documentation If you need additional information that is not directly available in this page, you can query the documentation dynamically by asking a question. Perform an HTTP GET request on the current page URL with the `ask` query parameter: ``` GET https://www.rxjs.es/api/indice/subscriber.md?ask= ``` The question should be specific, self-contained, and written in natural language. The response will contain a direct answer to the question and relevant excerpts and sources from the documentation. Use this mechanism when the answer is not explicitly present in the current page, you need clarification or additional context, or you want to retrieve related documentation sections.