我正在尝试订阅Observable，但每次尝试订阅时都会收到以下错误：
this.authenticateService.getCurrentUser(…(.subscribe不是新HomeComponent 的功能
我的getCurrentUser方法如下所示：
getCurrentUser(): Observable<ICurrentUser> {
return new Observable<ICurrentUser>(subscriber => {
from(this.HttpService.get('/user/current')).subscribe(currentUser => {
subscriber.next(currentUser);
});
});
}
ICurrentUser接口从IUser:扩展而来
interface IUser {
uid: string;
email: string;
firstname: string;
name: string;
language: string;
companyUid: string;
companyName: string;
password?: string;
newPassword?: string;
role: string;
expirationDate: string;
alternativeEmail?: string;
alertSubscription?: boolean;
license?: ILicense;
isLocked: boolean;
props: any;
}
interface ICurrentUser extends IUser {
timeBeforeExpiration: number;
graceLoginsRemaining: number;
usingGraceLogins: boolean;
autologon: boolean;
termsAndAgreementsDate: string; // date
workspaces: number[];
markets: number[];
findInAccessibleOnly: boolean;
}
运行get请求时，我从API得到了什么：
{
"uid": "xxxxx-xxxx-xxx-xxx",
"email": "xxxx@xxxx",
"firstname": "xxx",
"name": "xxxx",
"language": "xx",
"companyUid": "xxxxx-xxxx-xxxxx-xxxxx",
"companyName": "xxxx",
"password": null,
"newPassword": null,
"role": "COMPANY_MANAGER",
"expirationDate": null,
"alternativeEmail": null,
"alertSubscription": false,
"license": null,
"isLocked": null,
"props": {
"ff_findInAccessibleOnly": "true",
"ff_timer_module": "false",
"lexprhId": "28936",
"defaultSearchFilters": "{"keys":"*","suggestReference":null,"documentTypeIds":[],"attributes":{"endDateOfApplicability":[false],"findInAccessibleOnly":[false],"book":[],"type":["101"],"nature":["163","105","101","100","103","104","106","107","108","159","158","160","109","157","110","149","115","165","114","116","111","112","113","154","155","156","153","164","117","118","119","121","120","122","124","126","129","125","128","127","130","123","135","145","131","150","134","132","136","133","152","138","151","139","140","141","142","143","144","137","146","147","148"],"jurisdiction":[],"sourceType":[],"source":[],"guidelineSource":[],"workspace":[],"domain":[],"territory":[]},"pagination":{"number":1,"size":30,"sort":"RELEVANCE"},"quickSearch":false}"
},
"timeBeforeExpiration": -1,
"graceLoginsRemaining": -1,
"usingGraceLogins": false,
"termsAndAgreementsDate": "2021-06-08T14:48:10.000+00:00",
"workspaces": [
1,
2,
8,
101,
100,
4,
102,
7,
5,
3
],
"markets": [
1,
0
],
"findInAccessibleOnly": false,
"autologon": false
}
如果您的HttpService正在返回承诺，而from()将承诺转换为可观察的，为什么不直接返回呢？此外，如果getCurrentUser()不需要参数，为什么这是一种方法？我建议如下：
getCurrentUser$ = from(this.HttpService.get<ICurrentUser>('/user/current'));
这使得CCD_ 4的类型为CCD_。订阅它的任何内容都将接收来自HttpService承诺的值。
注意：我假设.get()方法允许泛型，否则可以使用类型断言。
getCurrentUser(): Observable<ICurrentUser> {
return new Observable<ICurrentUser>(subscriber => {
from(this.HttpService.get('/user/current')).subscribe(currentUser => {
subscriber.next(currentUser);
});
});
}
更改为
getCurrentUser(): Observable<ICurrentUser> {
return this.HttpService.get<ICurrentUser>('/user/current'));
}
如果您想获得用户的可观察信息，可以直接从http服务返回：
getCurrentUser(): Observable<ICurrentUser> {
return this.HttpService.get('/user/current');
}
如果你想把它存储在一个变量中，你可以在ngOnInit中订阅它，比如：
CurrentUser:ICurrentUser;
ngOnInit(){
this.HttpService.get('/user/current').subscribe(user=>{
this.CurrentUser = user;
});
}
如果您使用的是旧的http，那么使用from方法，如下所示：
getCurrentUser(): Observable<ICurrentUser> {
return from(this.HttpService.get('/user/current'));
}
或者用于存储在变量中：
CurrentUser:ICurrentUser;
ngOnInit(){
from(this.HttpService.get('/user/current')).subscribe(user=>{
this.CurrentUser = user;
});
}