Back to questions
Middle
4
Задача по RxJS: определить вывод при использовании combineLatest с двумя стримами с разными задержками. Что выведет forkJoin?
Companies where asked
Цифротех
Answer from AI
sobes.tech AI
forkJoin в RxJS ждёт завершения всех переданных Observable и выдаёт массив последних значений каждого из них. Если один из стримов не завершится, forkJoin не сработает.
Например, если есть два стрима с разными задержками, forkJoin выдаст результат только после того, как оба стрима завершатся, и в массиве будут их последние эмитты.
Пример:
import { of, forkJoin, delay } from 'rxjs';
const stream1 = of('A').pipe(delay(1000));
const stream2 = of('B').pipe(delay(2000));
forkJoin([stream1, stream2]).subscribe(result => {
console.log(result); // Выведет ['A', 'B'] через ~2 секунды
});
Таким образом, forkJoin полезен, когда нужно дождаться завершения нескольких асинхронных операций и получить их результаты одновременно.