How do I create an observable in RxJS?

How do I create an observable in RxJS?

You can create an observable using the new Observable() constructor. Here's a simple example:

import { Observable } from 'rxjs';

const myObservable = new Observable(subscriber => {
  subscriber.next('Hello');
  subscriber.next('World');
  subscriber.complete();
});

What does the subscriber do in this context?

The subscriber is an object that allows you to send data to the observer. You can call methods like next(), error(), and complete() on it to emit values, signal an error, or indicate that the observable has finished emitting values.

Can I create an observable from an array?

Yes, you can use the from operator to create an observable from an array. Here's how:

import { from } from 'rxjs';

const array = [1, 2, 3];
const arrayObservable = from(array);
arrayObservable.subscribe(value => console.log(value));

What are some common operators I can use with observables?

Some common operators include map, filter, mergeMap, and switchMap. These operators allow you to transform, filter, and combine observables in various ways.