RxKotlin collectInto() MutableList using method references

Question

下面的代码是我尝试将RxJava示例转换为Kotlin。它应该将一堆Int收集到一个MutableList中，但我收到了很多错误。

val all: Single<MutableList<Int>> = Observable
.range(10, 20)
.collectInto(::MutableList, MutableList::add)

错误：

Error:(113, 36) Kotlin: Type inference failed: Not enough information to infer parameter T in inline fun <T> MutableList(size: Int, init: (index: Int) -> T): MutableList<T>
Please specify it explicitly.
Error:(113, 49) Kotlin: One type argument expected for interface MutableList<E> : List<E>, MutableCollection<E> defined in kotlin.collections
Error:(113, 67) Kotlin: None of the following functions can be called with the arguments supplied: 
public abstract fun add(element: Int): Boolean defined in kotlin.collections.MutableList
public abstract fun add(index: Int, element: Int): Unit defined in kotlin.collections.MutableList

如果我将ImmutableList::add更改为ImmutableList<Int>::add，我将摆脱类型参数预期错误，该错误替换为：

Error:(113, 22) Kotlin: Type inference failed: fun <U : Any!> collectInto(initialValue: U!, collector: ((U!, Int!) -> Unit)!): Single<U!>!
cannot be applied to
(<unknown>,<unknown>)

这是 Java 中以下内容的直接副本：

Observable<List<Integer>> all = Observable
.range(10, 20)
.collect(ArrayList::new, List::add);

我知道第一个错误告诉我它要么推断出不正确的类型，我需要更明确(在哪里？)，但我认为::MutableList相当于() -> MutableList<Int>。第三个错误是告诉我它不能用参数调用任何add()方法，但同样，我认为MutableList::add等同于{ list, value -> list.add(value) }。第四个错误告诉我它无法找出应用于collector的类型。

如果我改用 lambda 表达式，则没有错误：

val all: Single<MutableList<Int>> = Observable
.range(10, 20)
.collectInto(mutableListOf(), { list, value -> list.add(value) })
all.subscribe { x -> println(x) }

我希望对我在方法引用方面做错什么发表一些评论，因为显然我误解了一些东西(浏览 Kotlin 语言参考，我想知道它目前是否是一种语言功能？非常感谢。

Answer 1

在第一个示例中，您尝试将collect的方法签名应用于collectInto中的方法签名。

这永远行不通，因为collect期望一个Func0<R>和一个Action2<R, ? super T>，而collectInto期望一个真实的对象和一个BiConsumer<U, T>。
构造函数引用不能用于collectInto- 你需要一个真实的对象(例如你的mutableListOf()调用)

第二个问题是 Kotlin 期待的是BiConsumer对象而不是函数。我不太清楚为什么。显然，Kotlin 无法处理来自 SAM-Interface 的 lambda 和函数引用的多个泛型。

因此，您需要传递BiConsumer的实例，而不仅仅是函数。
这也是我在评论中问您是否确定错误消息的原因：

range(10, 20).collectInto(mutableListOf(), { l, i ->  l.add(i) }) 

会给我一个错误，而

range(10, 20).collectInto(mutableListOf(), BiConsumer { l, i ->  l.add(i) })

不会。