У меня есть следующий класс и метод, используемые в приведенном ниже коде, где ids
является Set[String]
:
case class PAV ()
def aggregate(pId: String, iId: Option[String], count: Int): PAV
Я пробовал следующее:
Один, используя java.util.stream.Collectors
tuple._2.get.ids.toStream
.map(i => aggregate("some", Option(i), tuple._1.data.`type`))
.collect(Collectors.toList[PAV]) // required PartialFunction found Function0
Два, используя identity
tuple._2.get.ids.toStream
.map(i => aggregate("some", Option(i), tuple._1.data.`type`))
.collect(identity(PAV)) // required PartialFunction found PAV.type
Я пробовал описанное выше на основе Как использовать поток java 8, получаемый из scala 2.11?
Интересно узнать, почему бы не предоставить Function
до collect
?