how to use the subscriber function from the rxjs library in javascript

index.tsx
const { Observable } = require('rxjs');

// create an observable that emits values 1, 2, 3
const observable$ = new Observable((observer) => {
  observer.next(1);
  observer.next(2);
  observer.next(3);
});

// create a subscriber which logs each emitted value
const subscriber = {
  next: (value) => console.log(value),
  error: (error) => console.error(error),
  complete: () => console.log('completed')
};

// subscribe to the observable
observable$.subscribe(subscriber);
475 chars
19 lines