Android RxAndroid和RxJava2在Kotlin中的使用

implementation 'io.reactivex.rxjava2:rxandroid:2.0.2'
implementation 'io.reactivex.rxjava2:rxjava:2.1.10'

Observable.timer(1000, TimeUnit.MILLISECONDS)
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe {  }

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)
        })