Я не знаю ваш реальный код, это псевдокод, и я не знаю, какую версию rxjs вы используете сейчас, но вы можете сделать что-то вроде ниже:
при условии, что вы используетеrxjs 6:
iif(condition, obervable1, concatMap(observable1, observable2))
.subscribe()