Спасибо за отличную статью. Кажется, что с rxjs 6 await click$.take(10).forEach((_, i) => console.log(`click ${i + 1}`)); должно быть await click$.pipe(take(10)).forEach((i) => console.log(`click ${i + 1}`));