在下面的示例中，我试图缩小用例。
我被困在需要传递运算符结果的地方
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 })
)
concatMap((item: number) => {
return defer(testFunctionPromise(item)).pipe(
map(result => ({
item: result
})),
);
})
或者，如果您想item用作属性：
map(result => ({
[item]: result
})),
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句