RxJs - startWith

Оператор

1

startWith

- добавляет начальное значение в поток. То есть - в начало потока добавляется значение, которое передается в

1	startWith()

как аргумент; потом уже - пойдут значения самого потока:

import { interval, Observable } from 'rxjs'; 
import { startWith, take } from 'rxjs/operators';

const stream$: Observable<string | number> = interval(1000).pipe(
  startWith('welcome'),
  take(5)
);
stream$.subscribe((v: string | number) => console.log(v));

Вывод будет таким:

welcome
0
1
2
3

Обратить внимание! Выведен поток из пяти элементов! Начальное значение

1

welcome

также учитывается оператором

1

take()

!

Обратить внимание! В данном случае от потока отписываться не нужно, так как оператор

1

take()

сам отпишет (

1	complete()

) данный поток по завершении своей работы - особенность работы этого оператора

1

take()

!

---