Observable.subscribe 上的 Kotlin 扩展函数不起作用

Question

我正在尝试为 Observable.subscribe 编写一个自动记录错误的扩展函数。

fun <T> Observable<T>.subscribeAndLogE(onNext: Consumer<in T>): Disposable =
    subscribe(onNext, ErrorConsumer())

ErrorConsumer 工作并可能记录错误，但是 subscribeAndLogE不接受像 .subscribe() 这样的 lambda确实如此。

observer.subscribe { 
                //works
           }

observer.subscribeAndLogE { 
                //does not work
           }

它说:

OnboardingScreen 为任意值 T通常是这样。

我没有看到原文Consumer<in T>在Observable做任何特殊的事情来接受 lambda。我在这里做错了什么？

Answer 1

您正在将 Consumer 类型的参数传递给函数。您需要传递一个函数才能使 lambda 语法发挥作用。这将按照您想要的方式工作:

fun <T> Observable<T>.subscribeAndLogE(onNext: (it : T) -> Unit): Disposable =
        subscribe({ onNext(it) },{ throwable -> Log(throwable) })

并像这样使用它:

observer.subscribeAndLogE { 
                //works
           }