【发布时间】:2025-12-28 19:15:13
【问题描述】:
我正在使用io.reactivex.rxkotlin 扩展功能:
fun <T : Any> Observable<T>.subscribeBy(
onError: (Throwable) -> Unit = onErrorStub,
onComplete: () -> Unit = onCompleteStub,
onNext: (T) -> Unit = onNextStub
): Disposable
当我使用这个扩展时,如果我选择发送参数或使用 lambda,就会有所不同。 例如
首次实施:
myObservable.subscribeBy { str ->
// onNext
}
第二次实施:
myObservable.subscribeBy({ throwable ->
// onError
})
- 在第一个实现中,函数是
onNext - 在第二个实现中,函数是
onError
我不知道为什么。
【问题讨论】:
标签: kotlin kotlin-extension rx-kotlin