У RxJs існує два види операторів.
Канальні (pipeble), які можуть бути вставлені у канал наступним чином.
observableInstance.pipe(operator())
Наприклад filter(…) або mergeMap(…)
Вони не змінюють існуючий екземпляр потоку, а повертають новий потік, у якого логіка підписки така сама, як і у вихідного потоку.
Канальні оператори – це функції, які приймають вихідний потік як аргумент і повертають новий потік, не змінюючи вихідного.
Вони створюють нові потоки із різних джерел (масивів, подій тощо).
Наприклад of(1, 2, 3) створить відстежуваний потік, який згенерує 1, 2, і 3 один за одним.
Відмінність of і from у тому, що of([1,2,3]) згенерує потік з одного елемента масиву, а from([1,2,3]) з 3-х.
Канальні оператори - це прості функції, які можуть бути вкладені в канал так:
obs.pipe(
op1(),
op2(),
op3(),
op3(),
)
import { interval } from 'rxjs';
const observable = interval(1000 /* number of milliseconds */);
Спостерігаються потоки (НП) зазвичай генерують значення простих типів як числа, масиви і т.д.