AruarianZombie
2/4/2020 - 4:50 PM

Create your own Observable

Script que muestra la implementación de un observable propio. En pocas palabras crear tu propio observable que emite un simple saludo. Un ejemplo simple, que sin embargo puede ser de utilidad al implementar nuestros propios observables. La estructura no cambia independientemente del valor que se desee emitir; siempre tendras que tener la definición del observable, emitir con (next) el valor, o emitir un error (error) y completar (complete). La versión que se maneja para la implementación de este script de rxjs es 5.4.1

yourObservable.ts
content_copyfile_download
import { Observable } from 'rxjs';
import { PartialObserver } from 'rxjs/Observer'

let greet$: Observable<string> = Observable.create((observer: PartialObserver<string>) => {
  observer.next('konichiwa');
  oserver.complete();
});

greet$.subscribe({
  next: (greet: string) => {
    console.log(`${greet}, developer-san`);
    console.log('xd');
  },
  error: (e) => console.log(e),
  complete: () => console.log('Saludo completado')
})