我有一个可观察的numberRange$
,它发出一系列数字,比如[65, 66, 67, 68]
。
是否有任何数字可以订阅numberRange$
并将数组中的每个数字作为新管道中的单独排放?
每个数字将用作异步http调用的输入,并且使用mergeMap
批处理http调用是微不足道的,因为api一次只允许2个并行计算。
现在,我正在订阅numberRange$
并将输出保存在变量numberRange$
中并使用rxjs/operators.from(numberRange).pipe(mergeMap(someFunc, batchCount))
执行操作,但我宁愿直接管道numberRange$
并在击中mergeMap
之前将阵列拆分为单独的排放。
谢谢你的好答案!
当然,我认为你可以使用mergeMap
分裂情绪。
numberRange$.pipe(
mergeMap(nums => nums) // mergeMap(nums => from(nums))
).subscribe(console.log);
你可以使用concatMap
:
import { of } from 'rxjs';
import { concatMap } from 'rxjs/operators';
of([65, 66, 67, 68]).pipe(concatMap(x => x)).subscribe(console.log);