以下の例で、ユースケースを削減しようとしました。
持つべき演算子の結果を渡す必要がある時点で立ち往生しています
- 演算子の入力が渡されました
- および 内の延期操作の結果
concatMap
。
次のオペレーターに使用できるようにします。
import { of, from, defer } from 'rxjs';
import { mergeMap, filter, concatMap, map, reduce } from 'rxjs/operators';
const list: number[] = [1, 2, 3, 4, 5, 6];
function testFunctionPromise(value: number) {
return () => {
return new Promise((resolve, reject) => {
setTimeout(() => {
return resolve('processed-value ' + value);
}, 1000);
});
}
}
from(list)
.pipe(
filter((item: number) => item % 2 === 0),
concatMap((item: number) => {
const pf = testFunctionPromise(item);
/**
* QUESTION: from this step I want to pass both
* the result of defer(pf); and item
*
* as
*
* return { item: <result of defer(pf)> }
*
*/
return defer(pf);
}),
reduce((acc: any[], item: any) => acc.concat([item]), [])
)
.subscribe(
data => console.log({ data }),
error => console.error({ error })
)