Why subject.next(2); not works? I know it may happens because the signal stream got error. But I add catchError and I return a EMPTY in the pipeline and it make it complete.

So seems catchError not helping me either.

How to make subject.next(2) works?

My code is calling to doWork function. inside I invoke work function. if it's one I simulate an error at the first time I call the function, after that should not have error.

Then I expose the subject and the subject-pipeline to do something else after the pipeline is invoked. I use share for that (to not duplicate my flow) and it should be happens only once.

stackblitz.com

import { EMPTY, of, Subject, throwError } from 'rxjs';
import { exhaustMap, share, take, tap } from 'rxjs/operators';

console.clear();

const doWork = () => {
  const subject = new Subject();

  const work = (n) => {
    console.log('in work fn', n);
    if (n === 1) {
      throw new Error('bla');
    }
    return of([]);
  };

  const pipe = subject.pipe(
    exhaustMap((n) => work(n)),
    share()
  );

  pipe.subscribe({
    next: () => console.log('in subjectPipe next'),
    error: () => console.log('in subjectPipe error'),
    complete: () => console.log('in subjectPipe complete'),
  });

  return { subject, pipe };
};

const { subject, pipe } = doWork();

pipe
  .pipe(
    take(1),
    tap(() => console.log('continue the pipe...'))
  )
  .subscribe({
    next: () => console.log('in subject next'),
    error: () => console.log('in subject error'),
    complete: () => console.log('in subject complete'),
  });

subject.next(1);
subject.next(2);