акка-акторах и мне нужно его допилить
код такой
Future
.sequence(peers
.map(peer => (peer ? _ValueForKey(key))(peerConnectionTimeout))
.map(_.transform(Success(_))))
.map { responses =>
responses
.collect { case Success(x: PersistedDataStoreValue) => x }
.groupBy(_.creationTimestamp)
.maxBy(_._1)
._2
}
.flatMap { latestKeyValueOccurences =>
val occurences = latestKeyValueOccurences.length
val responseVal = latestKeyValueOccurences.head.value
val x = if (occurences < r) None else Some(responseVal)
Future(GetResponse(key, x))
}
}
.pipeTo(sender)суть в том, что я отправляют пирам запрос. могу получить либо Success со своим респонсом (но так как я использую старые акторы, респонс не типизирован) поэтому Try[Any]
аа, ясно
какая скала
у вас в первой части в transform Try оборачивается в Success
Обсуждают сегодня