我们在ngrx的ComponentStore中有两个效果。
readonly startAndUpdateProgress = this.effect<void>(
(trigger$) => trigger$.pipe(
exhaustMap(() =>
this.numbersObservable.pipe(
tapResponse({
next: (progress) => this.updateIrisFileListProgress(progress),
error: (error) => console.error(error)
})
)
)
)
);
readonly postFileToServer = this.effect((formData$: Observable<FormData>) => {
return formData$.pipe(
switchMap((formData) => {
return this.schemaUploadSrvice.postFiles(formData).pipe(
tapResponse(
(response) => this.updateSchemaUploadServerResponse(),
(error: HttpErrorResponse) => console.error(error),
)
)}),
);
});
我想等待 startAndUpdateProgress 完成后再调用 postFileToServer。 有什么方法可以同步执行此操作。
您可以在
postFileToServer
效果中调用 startAndUpdateProgress
。