如何解决在Angular8中使用管道和HttpService时简化API调用
在我的大多数API调用中,我都使用以下模式:
-
呼叫服务器和管道结果
-
检查错误并在需要时抛出
-
服务器的地图结果
public getItems():Observable
- {
var socket = io.connect("http://" + document.domain + ":" + location.port + "/some_namespace");
}
是否可以将catchError和map操作符合并为一个操作符?
类似这样的东西:
return this.http.get<Item[]>>(environment.url + '/items').pipe(
catchError((error:any)=> throwError('Failed getting items')),map((ret)=> this.mapResults(ret)));
itemForMapping将进入映射功能。这样的东西?
catchErrorAndMap("Message in case of error",itemForMapping)
解决方法
是的。 RxJS运算符只是一个函数。因此,您可以编写自己的RxJS运算符。
这里有一个示例:https://netbasal.com/creating-custom-operators-in-rxjs-32f052d69457
在标题为“从现有操作员中创建操作员”的部分中。
因此,您可以创建一个catchErrorAndMap
函数,然后将其用作运算符。
这里是一个例子:
export function catchErrorAndMap(errorMessage): OperatorFunction<User[],User[]> {
return source =>
source.pipe(
catchError((error: any) => throwError(errorMessage)),map(items => items.map(item => ({ ...item,name: item.name + "'s"} as User)))
);
}
这将创建一个接收Observable
然后通过所需的运算符通过管道传递源(源流中发出的项目)。
在此示例中,我使用了适合于我的数据的映射操作。您当然可以将其更改为您的this.mapResults()
。
您将像其他任何管道运算符一样调用此运算符:
users$ = this.http
.get<User[]>(this.userUrl)
.pipe(catchErrorAndMap("Error Occurred"));
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。