logcat和toast的rxjava onnext方法

我刚接触到RXJava。

我正在学习在线资源并加以实施。 我正在尝试编写非常简单的代码,但我遇到了一些问题。

var animalobservable: Observable<String> = Observable.just("Ant", "Bee", "Cat", "Dog", "Fox")
var animalObserver: Observer<String> = getAnimalObserver()

animalobservable
    .subscribeOn(Schedulers.trampoline())
    .debounce(3, TimeUnit.SECONDS)
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(animalObserver)

我在下一个方法中做了一些事情。

private fun getAnimalObserver(): Observer<String> {
    return object : Observer<String> {
        override fun onSubscribe(d: Disposable) {
            Log.d("OnSubscibe", "onSubscribe")
        }

        override fun onNext(s: String) {
            Log.d("OnNext", "Name: $s")
            Toast.makeText(context, "Name : $s", Toast.LENGTH_SHORT).show()
        }

        override fun onError(e: Throwable) {
            Log.e("OnError", "onError: " + e.message)
        }

        override fun onComplete() {
            Log.d("OnComplete", "All items are emitted!")
        }
    }
}

我的问题 当我将一些代码打印到logcat中时,它会正常工作。一个接一个发出的数据。

但当我烤它而不是logcat时,它只发出最后的数据“fox”。

我想知道Toast和Logcat的问题是什么。我假设它是由于线程而发生的,但我不明白为什么会发生。

事先谢谢….!