java - 自定义调度程序上未调用 RxJava Hook

Question

我已经通过注册了一个钩子(Hook)

RxJavaHooks.setOnScheduleAction(new MyOnScheduleAction());

并使用创建了一个自定义调度程序(用于测试目的)

Scheduler scheduler = Schedulers.from(Executors.newSingleThreadExecutor());

但是下面的代码没有调用注册的钩子(Hook):

Observable.create(subscriber -> {
    subscriber.onNext("Hi");
    subscriber.onComplete();
}).subscribeOn(scheduler).subscribe(myTestSubscriber);

但是，如果我将 subscribeOn(scheduler) 替换为 subscribeOn(Schedulers.io()) (或 subscribeOn(Schedulers.computation())，就此而言)该钩子(Hook)按预期被调用。

这是预期的行为吗？我正在使用 RxJava 1.1.8。

Answer 1

这是 Schedulers.from() 的一个错误，将在 1.1.9 中修复。您可以追踪相关问题/pr here .