PM
Denis G
я думал он только в Яве, а в скале такого нету
или я что-то путаю
или я что-то путаю
компилятся они все в одно и то же
я думал он только в Яве, а в скале такого нету
или я что-то путаю
Size: a a a
2020 April 23
Oℕ
Denis G
скала на том же рантайме запускается
DG
спасибо большое!
я скорее всего ожидал, что он сделает какие-то чеки, хоть в рантайме, аля инстансОфы
благодарю
я скорее всего ожидал, что он сделает какие-то чеки, хоть в рантайме, аля инстансОфы
благодарю
Oℕ
Denis G
спасибо большое!
я скорее всего ожидал, что он сделает какие-то чеки, хоть в рантайме, аля инстансОфы
благодарю
я скорее всего ожидал, что он сделает какие-то чеки, хоть в рантайме, аля инстансОфы
благодарю
можно сделать так
case Success(x: PersistedDataStoreValue) => x
Oℕ
тогда будет проверка
DG
то, что нужно)
спасибо
спасибо
PM
Denis G
то, что нужно)
спасибо
спасибо
вопрос только зачем она
PM
есть у вас Try[T], то в Success всегда будет Т
Oℕ
В нетипизированных акторах всякое бывает
PM
насколько я помню, Т инвариантен
DG
зачем, что?
в двух словах у меня старый проект на нетипизированных акка-акторах и мне нужно его допилить
код такой
в двух словах у меня старый проект на нетипизированных акка-акторах и мне нужно его допилить
код такой
Futureсуть в том, что я отправляют пирам запрос. могу получить либо Success со своим респонсом (но так как я использую старые акторы, респонс не типизирован) поэтому
.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)
Try[Any]PM
хотя если там List[Try[Any]]...
PM
Denis G
зачем, что?
в двух словах у меня старый проект на нетипизированных акка-акторах и мне нужно его допилить
код такой
в двух словах у меня старый проект на нетипизированных акка-акторах и мне нужно его допилить
код такой
Futureсуть в том, что я отправляют пирам запрос. могу получить либо Success со своим респонсом (но так как я использую старые акторы, респонс не типизирован) поэтому
.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)
Try[Any]аа, ясно
Oℕ
Denis G
зачем, что?
в двух словах у меня старый проект на нетипизированных акка-акторах и мне нужно его допилить
код такой
в двух словах у меня старый проект на нетипизированных акка-акторах и мне нужно его допилить
код такой
Futureсуть в том, что я отправляют пирам запрос. могу получить либо Success со своим респонсом (но так как я использую старые акторы, респонс не типизирован) поэтому
.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)
Try[Any]какая скала
DG
не дотти ((
DG
2.12.11 вроде
Oℕ
2.13 ?
Oℕ
ладно
Oℕ
в map лучше не делать сайд эффектов
Oℕ
последний flatMap упрощается до map