Наблюдаемые — это фундаментальная концепция реактивных расширений для JavaScript (RxJS). Они позволяют нам работать с асинхронными потоками данных и выполнять над ними различные операции. В этой статье мы рассмотрим пять различных методов создания наблюдаемых из значений в RxJS, а также приведем примеры кода.

Метод 1: оператор of
Оператор ofпозволяет нам создать наблюдаемую величину, которая генерирует последовательность значений, а затем завершается.

import { of } from 'rxjs';
const source$ = of(1, 2, 3);
source$.subscribe(value => console.log(value));

Метод 2: оператор from
Оператор fromпреобразует различные другие объекты и типы данных в наблюдаемую последовательность.

import { from } from 'rxjs';
const source$ = from([1, 2, 3]);
source$.subscribe(value => console.log(value));

Метод 3: оператор fromEvent
Оператор fromEventсоздает наблюдаемую величину, которая генерирует события из указанной цели события.

import { fromEvent } from 'rxjs';
const button = document.querySelector('button');
const source$ = fromEvent(button, 'click');
source$.subscribe(event => console.log(event));

Метод 4: оператор interval
Оператор intervalвыдает последовательные числа через указанный интервал времени.

import { interval } from 'rxjs';
const source$ = interval(1000);
source$.subscribe(value => console.log(value));

Метод 5: оператор create
Оператор createпозволяет создать собственный наблюдаемый объект, определив логику подписки.

import { Observable } from 'rxjs';
const source$ = new Observable(observer => {
  observer.next(1);
  observer.next(2);
  observer.next(3);
  observer.complete();
});
source$.subscribe(value => console.log(value));

В этой статье мы рассмотрели пять различных методов создания наблюдаемых из значений в RxJS. Операторы of, from, fromEvent, intervalи createобеспечивают гибкость работа с различными типами источников данных и событий. Используя эти методы, вы можете создавать мощные реактивные потоки в своих приложениях.