DG
поэтому и оборачивал в Try, чтобы избежать исключения по тайм-ауту
Size: a a a
2020 April 23
Oℕ
Когда вы оборачиваете в Success вы просто берёте именно этот Failure и оборачиваете его в Success , ваш актор не перестаёт таймаутить
Oℕ
Т.е. у вас во фьюче
Failure(AskTimeoutException в качестве результата
Failure(AskTimeoutException в качестве результата
Oℕ
Чинить нужно актор
DG
Чинить нужно актор
а что с ним не так?
я спрашиваю N пиров, если из них хотя бы K дают правильный вариант, но все круто и я отвечаю
я спрашиваю N пиров, если из них хотя бы K дают правильный вариант, но все круто и я отвечаю
Some(x) или None соответственноDG
или вы имеете в виду, что тайм-ауты неправильно поставленны
Oℕ
Denis G
а что с ним не так?
я спрашиваю N пиров, если из них хотя бы K дают правильный вариант, но все круто и я отвечаю
я спрашиваю N пиров, если из них хотя бы K дают правильный вариант, но все круто и я отвечаю
Some(x) или None соответственноя не знаю, что с вашим актором не так, но он не отвечает на ваше сообщение за секунду и редактируя потребляющий код, вы это не исправите
Oℕ
именно ваши пиры
Oℕ
А ещё из вашего сообщения показалось, что этот код с асками вы тоже внутри актора запускаете
DG
я не знаю, что с вашим актором не так, но он не отвечает на ваше сообщение за секунду и редактируя потребляющий код, вы это не исправите
ну реализация
я не совсем понял ваш ответ. ну не ответил он за секунду или 5, не важно. Я же поставил тайм-аут. Если не отвечают за X секунд, я получаю Future из фэйла
_ValueForKey простаcase _ValueForKey(key) => dataStore.get(key).foreach(sender ! _)я не совсем понял ваш ответ. ну не ответил он за секунду или 5, не важно. Я же поставил тайм-аут. Если не отвечают за X секунд, я получаю Future из фэйла
Oℕ
Аски не нужно запускать внутри акторов
DG
что такое аски? 😅
DG
аа
DG
ask, понял
Oℕ
actorRef ? message
DG
Аски не нужно запускать внутри акторов
то есть?
DG
peer это и есть actorRef
DG
val peers = self::successors.map(_.ref)Oℕ
код который вы скинули, он внутри актора работает?
DG
да