如何使用Rxjava过滤Android Kotlin中的数据

implementation 'io.reactivex.rxjava3:rxjava:3.x.x'

import io.reactivex.rxjava3.core.Observable
import io.reactivex.rxjava3.core.Observer
import io.reactivex.rxjava3.disposables.Disposable
import io.reactivex.rxjava3.schedulers.Schedulers

val numbers = listOf(1, 2, 3, 4, 5, 6, 7, 8, 9, 10)

val observable = Observable.fromIterable(numbers)

val filteredObservable = observable
    .filter { number -> number % 2 == 0 }

val observer = object : Observer<Int> {
    override fun onSubscribe(d: Disposable) {
        // 当订阅时调用
    }

    override fun onNext(number: Int) {
        // 当接收到过滤后的数据时调用
    }

    override fun onError(e: Throwable) {
        // 当发生错误时调用
    }

    override fun onComplete() {
        // 当所有数据都被接收时调用
    }
}

filteredObservable
    .subscribeOn(Schedulers.io()) // 在IO线程进行过滤操作
    .observeOn(AndroidSchedulers.mainThread()) // 在主线程处理过滤后的数据
    .subscribe(observer)