BufferAndTrampoline.kt

val subject = PublishSubject.create<Int>()

// 処理が終わらない
subject
    .subscribeOn(Schedulers.trampoline()) // テストコードではRxJavaPluginsによってtrampolineがsetされる
    .buffer(1, TimeUnit.SECONDS)
    .filter { it.isNotEmpty() }
    .subscribe { buffers -> println(buffers) }

// これは大丈夫
subject
    .subscribeOn(Schedulers.trampoline())
    .subscribe { value -> println(value) }