我之前使用RxJava和Kotlin遇到了一些问题.我做了一些有趣的发现,我仍然感到困惑.
Func1
RxJava中有简单的界面
public interface Func1extends Function { R call(T t); }
我试图添加一个扩展方法Observable
,也是一个RxJava类.这会将排放物收集到Google Guava中,ImmutableListMulitmap
使用a Func1
来映射每个项目的关键字.
funObservable .toImmutableListMultimap(keyMapper: Func1 ): Observable > { return this.collect({ ImmutableListMultimap.builder ()},{ b, t -> b.put(keyMapper.call(t), t)}).map { it.build() } }
当我试图调用这个扩展方法时,我无法进行编译,而且根本不理解lambda表达式.
ScheduledItem.all.flatMap { it.rebuildSoftTransactions } .toImmutableListMultimap { it.id /*compile error */ } .cache()
但是,当我修改扩展方法以使用函数类型时,最奇怪的事情发生了.
funObservable .toImmutableListMultimap(keyMapper: (T) -> K): Observable > { return this.collect({ ImmutableListMultimap.builder ()},{ b, t -> b.put(keyMapper(t), t)}).map { it.build() } }
然后一切编译得很好.但这让我感到困惑:为什么它没有将lambda推断到界面上?当我使用标准map()
方法时,Observable
它使用大括号{ }
语法推断lambda就好了.但为什么它不适用于我上面的扩展方法?
SAM转换(将lambda转换为函数类型)目前仅适用于用Java编写的方法.Kotlin具有适当的函数类型,因此不需要SAM转换 - 您可以直接将参数声明为函数类型(正如您所观察到的那样有效).
Observable.map()
是用Java编写的,因此应用了SAM转换.您的扩展功能是用Kotlin编写的,所以不是.