使用一个调用observable的函数,该函数将3个不同的observable与switch-map绑定在一起.导致错误



我有一个函数,当文件上传到html表单时运行。

uploadidnexttofacepicture(event){
let subscription = this.s3service.publicresourceuploadtos3(event)
.subscribe((req: any)=>{
console.log(req);
});

}

该函数从注入的服务调用函数CCD_ 1。该功能显示在下面:

publicresourceuploadtos3(event): Observable<any>{
console.log('the service at least ran');
const mediatobeuploaded = event.target.files[0];
this.http.get(environment.public_generate_presigned_url_resource).pipe(
switchMap((req : any)=>{
console.log('did the call to the server');
const resourceurl = req.uriroot + req.fields.key;
let fd = new FormData();
fd.append('acl', req.fields.acl);
fd.append('key', req.fields.key);
fd.append('content-type', req.fields['content-type']);
fd.append('policy', req.fields.policy);
fd.append('x-amz-algorithm', req.fields['x-amz-algorithm']);
fd.append('x-amz-credential', req.fields['x-amz-credential']);
fd.append('x-amz-date', req.fields['x-amz-date']);
fd.append('x-amz-signature', req.fields['x-amz-signature']);
fd.append('file', mediatobeuploaded);
this.http.post(req.url, fd).pipe(
switchMap((req2: any)=>{
const result = {
resourceurl : resourceurl,
resourcekey: req.fields.key
};
return of(result);

}));

}));

}

控制台日志console.log('the service at least ran');确实在控制台中激发,但服务器调用一个:console.log('did the call to the server');没有。

但这导致了一个错误:

ERROR TypeError: Cannot read property 'subscribe' of undefined
at ContentcreatorverificationComponent.uploadidnexttofacepicture

我担心这是一个语法问题,如果你们中的任何人知道发生了什么,这将是有帮助的。

尝试在this.http.get(environment.public_generate_presigned_url_resource)之前添加return

它应该像这个

publicresourceuploadtos3(event): Observable<any>{
console.log('the service at least ran');
const mediatobeuploaded = event.target.files[0];
return this.http.get(environment.public_generate_presigned_url_resource).pipe(
switchMap((req : any)=>{
console.log('did the call to the server');
const resourceurl = req.uriroot + req.fields.key;
let fd = new FormData();
fd.append('acl', req.fields.acl);
fd.append('key', req.fields.key);
fd.append('content-type', req.fields['content-type']);
fd.append('policy', req.fields.policy);
fd.append('x-amz-algorithm', req.fields['x-amz-algorithm']);
fd.append('x-amz-credential', req.fields['x-amz-credential']);
fd.append('x-amz-date', req.fields['x-amz-date']);
fd.append('x-amz-signature', req.fields['x-amz-signature']);
fd.append('file', mediatobeuploaded);
this.http.post(req.url, fd).pipe(
switchMap((req2: any)=>{
const result = {
resourceurl : resourceurl,
resourcekey: req.fields.key
};
return of(result);

}));

}));

}

最新更新