未订阅fromPromise生成的Observable却触发HTTP请求的问题咨询
问题解答:未订阅fromPromise创建的Observable却触发HTTP请求
核心原因很明确:fetch本身是立即执行的Promise,和RxJS的Observable订阅机制完全无关。
- 当你调用
fetch(...)的瞬间,HTTP请求就已经发送了——不管后续有没有把这个Promise传给fromPromise,也不管有没有订阅生成的saveCourse$Observable。 fromPromise只是把已存在的Promise包装成Observable,它不会改变Promise的「立即执行」特性。RxJS的Observable默认是惰性的(只有订阅才触发执行),但这里的Promise在被包装前就已经启动了请求。
如果想要让HTTP请求仅在Observable被订阅时才触发,需要用defer操作符延迟Promise的创建,确保请求在订阅阶段才执行:
this.form.valueChanges .pipe( filter(() => this.form.valid), switchMap(changes => defer(() => fetch(`/api/courses/${this.course.id}`, { method: 'PUT', body: JSON.stringify(changes), headers: { 'content-type': 'application/json' } }) )) ) .subscribe();
这里用switchMap切换到新的Observable,defer会在每次订阅时才执行内部函数、创建fetch Promise,这样就能保证请求只在订阅时发送,符合RxJS的惰性执行预期。
内容的提问来源于stack exchange,提问作者Othmane
相关产品推荐
相关产品推荐

