如何将 empy(scheduler) 迁移到 RxJS?
How to migrate empy(scheduler) to RxJS?
我有遗留代码需要迁移到 RxJS 6。有一行我不知道如何迁移那一行:
return empty(this.scheduler);
this.scheduler
是传递给 class 构造函数的一些调度程序。
我找到了有关如何迁移 empty()
的说明,只需使用常量 EMPTY
,但如何使用调度程序创建一个空的可观察对象?
2019 年 3 月更新:有一个打开的 PR 添加了 emptyScheduled()
方法:https://github.com/ReactiveX/rxjs/pull/4595
现在也弃用了 empty()
Observable 创建方法,推荐的方法是使用 EMPTY
:
import { EMPTY } from 'rxjs';
EMPTY
仅发出 complete
通知,因此它不接受任何调度程序。
编辑:
import { asyncScheduler, Observable } from 'rxjs';
const asyncEmpty = scheduler => new Observable(observer => {
scheduler.schedule(() => observer.complete());
});
asyncEmpty(asyncScheduler).subscribe({ complete: () => console.log('completed')});
我有遗留代码需要迁移到 RxJS 6。有一行我不知道如何迁移那一行:
return empty(this.scheduler);
this.scheduler
是传递给 class 构造函数的一些调度程序。
我找到了有关如何迁移 empty()
的说明,只需使用常量 EMPTY
,但如何使用调度程序创建一个空的可观察对象?
2019 年 3 月更新:有一个打开的 PR 添加了 emptyScheduled()
方法:https://github.com/ReactiveX/rxjs/pull/4595
现在也弃用了 empty()
Observable 创建方法,推荐的方法是使用 EMPTY
:
import { EMPTY } from 'rxjs';
EMPTY
仅发出 complete
通知,因此它不接受任何调度程序。
编辑:
import { asyncScheduler, Observable } from 'rxjs';
const asyncEmpty = scheduler => new Observable(observer => {
scheduler.schedule(() => observer.complete());
});
asyncEmpty(asyncScheduler).subscribe({ complete: () => console.log('completed')});