在Kotlin中使用函数引用重写Java代码发生SAM类型冲突

Question

我有一个使用方法引用的示例Java代码，我想重写给Kotlin。Java版本是使用方法参考的，解决方案简明扼要。但另一方面，我不能在Kotlin中使用方法引用。我写的唯一一个版本是下面的一个。看来function3{s:String,b：Boolean,i：Int->combine(s,b,i）}可以用更干净的方式编写（如果可能，方法引用将是完美的）。

我刚认识Kotlin所以如果有线索我会很感激的。

import io.reactivex.Observable;

public class TestJava {

    Observable<String> strings() {
        return Observable.just("test");
    }

    Observable<Boolean> booleans() {
        return Observable.just(true);
    }

    Observable<Integer> integers() {
        return Observable.just(1);
    }

    void test() {
        Observable.combineLatest(strings(), booleans(), integers(),
                this::combine);
    }

    double combine(String s, boolean b, int i) {
        return 1.0;
    }
}

import io.reactivex.Observable
import io.reactivex.functions.Function3

class TestKotlin {

    fun strings(): Observable<String> {
        return Observable.just("test")
    }

    fun booleans(): Observable<Boolean> {
        return Observable.just(true)
    }

    fun integers(): Observable<Int> {
        return Observable.just(1)
    }

    fun test() {
        Observable.combineLatest(strings(), booleans(), integers(),
                Function3 { s: String, b: Boolean, i: Int -> combine(s, b, i) })
    }

    fun combine(s: String, b: Boolean, i: Int): Double {
        return 1.0
    }
}

编辑

Kotlin中的以下方法引用给出了一个错误。

fun test() {
    Observable.combineLatest(strings(), booleans(), integers(), this::combine)
}

fun test() {
    Observable.combineLatest(strings(), booleans(), integers(), TestKotlin::combine)
}

不能使用提供的参数调用以下函数:@CheckReturnValue@SchedulerSupport public final fun combineLatest(p0:((Observer)->Unit)！,p1:(Observer)->Unit)！,p2:(Observer)->Unit)！,p3:((？？？,？？？,？？？）->？？？）！）：Observable<（？？？..？？？）>！在io.reactivex.observable@CheckReturnValue@SchedulerSupport public open fun combineLatest(p0:ObservableSource！,p1:ObservableSource！,p2:ObservableSource！,p3:io.reactivex.Functions.Function3！）中定义：Observable<(？？？..？？？）>！在io.reactivex.observable@checkreturnvalue@schedulersupport public open fun combineLatest(p0:function！,out（？？？..？？？）>！,p1:Int,vararg p2:observableSource！）中定义：observable<（？？？..？？？）>！在io.reactivex.observable中定义

编辑2

RxKotlin解决了答案中提到的问题。

import io.reactivex.rxkotlin.Observables

class TestKotlin {

    fun test() {
        Observables.combineLatest(strings(), booleans(), integers(), this::combine)
    }

}

Answer 1

您也可以在Kotlin中使用函数引用表达式，就像在Java中使用方法引用表达式一样。例如，combine函数引用为Kotlin中的Kfunction3，如下所示：

val f: kotlin.reflect.KFunction3<String, Boolean, Int, Double> = this::combine

在java中，方法引用表达式可以赋给任何兼容的函数接口，但是你不能给任何函数类型赋一个函数引用表达式，即使它们是兼容的，例如：

val f:io.reactivex.functions.Function3<String,Boolean,Int,Double> =this::combine
//                                                type mismatch error     ---^

实际上，Kotlin使用SAM转换将lambda/function引用表达式转换为Java函数接口的实现，这意味着Kotlin做了如下操作：

fun test() = TODO()

val exector:Executor = TODO()

exector.execute(::test)

//::test compile to java code as below:
Runnable task = new Runnable(){
   public void run(){
      test();
   }
};

基于以上内容，您可以看到RX-Java2中有许多重载的combineLatest方法。例如，以下两个就不能让Kotlin正确使用函数引用表达式：

combineLatest(
       ObservableSource<out T1>,
       ObservableSource<out T2>,
       ObservableSource<out T3>, 
       Function3<T1, T2, T3, out R>
)

combineLatest(
       ObservableSource<out T1>,
       ObservableSource<out T2>,
       ObservableSource<out T3>, 
       ObservableSource<out T4>, 
       Function4<T1, T2, T3, T4, out R>
)

正如我所说，Kotlin使用SAM转换将lambda/function引用表达式转换为Java函数接口，但它不能直接赋值给Java函数接口。

Kotlin中combineLatest方法的第4个参数，编译器根本无法推断其类型，因为第4个参数类型可以是io.reactivex.functions.function3或observableSource。因为observableSource也是一个Java函数接口。

typealias RxFunction3<T1, T2, T3, R> = io.reactivex.functions.Function3<T1,T2,T3,R>

val f: RxFunction3<String, Boolean, Int, Double> = RxFunction3{ s, b, i-> 1.0}

typealias RxFunction3<T1, T2, T3, R> = io.reactivex.functions.Function3<T1,T2,T3,R>

fun <T1,T2,T3,R> KFunction3<T1,T2,T3,R>.toFunction3(): RxFunction3<T1, T2,T3,R> {
    return RxFunction3 { t1, t2, t3 -> invoke(t1, t2, t3) }
}

那么可以使用函数引用表达式如下所示，例如：

Observable.combineLatest(
        strings(),
        booleans(), 
        integers(), 
        //             v--- convert KFunction3 to RxFunction3 explicitly
        this::combine.toFunction3()
)