TodoRxJS se basa enObservables.

Definición:

Es un objeto que puede emitir valores. Puede no emitir, emitir sólo uno, o emitir N cantidad de valores.

Declaración:

constobs$=newObservable<string>();

obs$ - Contiene un signo$ de pesos al final. Indica que la variable es un observable.

Observable<string>(); - Se crea una instancia deObservable, donde entre signos mayor y menor viene el tipo de dato devuelto en el observable. Entre los signos< > se especifica qué es lo que está fluyendo dentro delObservable. Pueden ser textos, numeros, modelos, clases, estructuras de datos, etc.Es muy importante definir qué tipo de dato fluye en elObservable.

Emisión de valores

Esto lo hacemos a través de la funciónnext().

constobs$=newObservable<string>(subs=>{subs.next("Hola");subs.next("Mundo");});obs$.subscribe(console.log);

Salida

subs.next() - Emisión de información.

En el ejemplo, se hacen 2 emisiones a los subscriptores."Hola" y"Mundo" que son textos.

Las emisiones se realizan siempre y cuando haya al menos un subscriber.

complete()

Este método hará que se detenga la emisión de información. Cadanext() después del métodocomplete(), ya no será emitido.

import{Observable}from'rxjs';// const obs$ = Observable.create(); También se puede crear así.constobs$=newObservable<string>(subs=>{subs.next("Hola");subs.next("Mundo");subs.complete();subs.next("Cruel");});obs$.subscribe(console.log);

En este ejemplo, la salida seguirá siendo la misma. La emisión después delcomplete() se omitirá.

Imagen deLuisella Planeta Leoni enPixabay