使自定义运算符具有可观察性

Question

const apiData = ajax('/api/data').pipe(map((res: any) => {
if (!res.response) {
console.log('Error occurred.');
throw new Error('Value expected!');
}
return res.response;
}),

我需要将管道函数封装到具有observable的自定义运算符中。需要将错误和数据验证处理到通用API服务中。

Answer 1

那么问题出在哪里呢？您可以用函数包装Observable和运算符。

const createObs = () => ajax('/api/data').pipe(
map((res: any) => {
if (!res.response) {
console.log('Error occurred.');
throw new Error('Value expected!');
}
return res.response;
}),
);
createObs().pipe(/* whatever */).subscribe();