Как завершить Observable по условию?

Question

[Fengol]

of(0,1,2,3).pipe(
 // ...
).subscribe({
  next:console.log,
  complete: console.log.bind(console, 'complete')
});

Answer 1

[Alex Karo]

Не спец в rxjs, но можно попробовать такое:

const stream = of(0,1,2,3);
const yourMagicCondition = x => x === 2;
const interrupter = stream.pipe(
  filter(yourMagicCondition),
  take(1),
);

stream.pipe(
  takeUntil(interrupter),
  merge(interrupter),
);

Comments

[Fengol]

Ваш вывод не соответствует тому, что я в требованиях к вопросу указал.