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

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();