我对这段代码有问题

val obs = PublishSubject.create<Int>()

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

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

当我使用subscribeonmainthread并调用onnext（）时，不会发生任何事情，也不会输出任何内容。。它可以与subscribeonschedulers.io（）或schedulers.computation（）配合使用
我不知道这是否是因为我已经在主线程中并调用subscribeon（androidschedulers.mainthread（）），但是当我尝试在某个随机工作线程中调用这些代码块时，它工作得很好