android - Rx subscribeOn mainThread 不适用于 PublishSubject Android

Question

我对这段代码有疑问

    val obs = PublishSubject.create<Int>()

    obs
        .subscribeOn(AndroidSchedulers.mainThread())
        .subscribe{ value -> 
              Log.i("TEST", "$value")
        }

    (1..4).forEach { obs.onNext(it) }

当我使用subscribeOn mainThread并调用onNext () 时，什么也没有发生，什么也没有打印出来。它与subscribeOn Schedulers.io()或Schedulers.computation()配合得很好

我不知道是不是因为我已经在主线程中并调用了subscribeOn(AndroidSchedulers.mainThread())但是当我尝试在一些随机工作线程中调用这些代码块时它运行良好