Obs1$.pipe( mergeMap((data) => { if (data.condition) { const generatedStuff = doSomethingFunction(data1);