Как выполнить `Collectors.toList ()` соответственно в scala - PullRequest
0 голосов
/ 22 января 2020

У меня есть следующий класс и метод, используемые в приведенном ниже коде, где 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?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...