RxJS Observable and observer

by ardydedase

HTML

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/6.6.7/rxjs.umd.min.js"></script>

TypeScript

const observable$ = new rxjs.Observable(observer => {
  observer.next(1);
  observer.next(2);
  observer.next(3);
  observer.next(3.5);
  setTimeout(() => {
    observer.next(4);
    observer.complete();
  }, 1000);
});

observable$.subscribe({
  next(x): void { console.log('got value ' + x); },
  error(err): void { console.error('something wrong occurred: ' + err); },
  complete(): void { console.log('complete'); }
});
console.log('just after subscribe');