implementation 'io.reactivex.rxjava2:rxandroid:2.0.2'
implementation 'io.reactivex.rxjava2:rxjava:2.1.10'
Kotlin
Observable.timer(1000, TimeUnit.MILLISECONDS)
.observeOn(AndroidSchedulers.mainThread())
.subscribe { }
常用的方式是分线程
中处理数据,主线程
中使用数据生成页面
Kotlin
Observable
.create<List<TreeItemModel>> { source ->
var treeList = arrayListOf<TreeItemModel>()
source.onNext(treeList)
source.onComplete()
}
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe({ treeList ->
print(treeList.size)
}, { error ->
print(error.localizedMessage)
})