Как вклинить другой поток после первого вызова исходного, и продолжить с результатами обеих?

Question

[bro-dev]

На первую дату потока нужно создать новый поток дождаться пока он закончится, в остальных датах изначального потока нужны данные и того нового и исходного.
Можно это как то сделать не плодя калбэкхэл?

a$.pipe(take(1)).subscribe(date=>{
    http(date).subscribe(response=>{
        a$.pipe(skip(1)).subscribe(date=>{
            myfn(response,date);
        })
    })
});

Comments

[SkaterDark]

Mak lo onak! Shin tel?

Answer 1

[dmestroone]

используйте forkJoin и switchMap операторы RxJS

forkJoin(
    a$.pipe(
        take(1),
        switchMap(date => http(date))
    ),
    a$.pipe(skip(1)) 
).subscribe(([response, date]) => {
    myfn(response,date);
});