RxJS Primer Ejemplo

index.js

import { Observable } from 'rxjs'

//desclaracion del observable
//parametro: un suscriptor
const observableAlfa$ = new Observable(subscriber => {
    //el observable emite una información al suscriptor
    subscriber.next(1)
    
    subscriber.next(2)
    // con complete, se da por completado el flujo de informacion y a partir de aqui no se emite mas
    subscriber.complete()
    subscriber.next(3)
    subscriber.next("Curso")
    //se puede emitir cuaquier tipo de informacion
    subscriber.next({
        test: true
    })
})

// el observador al que le llegará la informacion del observable
// todo observador tiene 3 metodos:
// - next(lo que se hace unando le llega la siguiente pieza de info desde el observable)
// - complete(lo que se hace cuando el onservador invoca el metodo complete)
// - error(lo que sucede cuando el observable tiene un error)
const observador = {
    next:(value)=>{
        console.log(value)
    },
    complete:()=>{

    },
    error: (error) =>{
        console.log("Error recibido:")
        console.error(error)
    }
}

//el observador se susucribe al observlabel
observableAlfa$.subscribe(observador)