akka

Существует ли идиоматический способ обработки первого элемента потока Akka Source особым образом? То, что у меня сейчас есть: var firstHandled = false source.map { elem => if(!firstHandled) { //handle specially firstHandled = true } else { //handle normally ...

Поэтому я уже некоторое время играю с актерами Akka и написал некоторый код, который может распределять вычисления между несколькими машинами в кластере. Перед запуском "основного" кода мне нужно иметь ActorSystem, ожидающий на каждой машине, которую я буду развертывать, и я обычно делаю это с помощью скрипта...

У меня есть сценарий, в котором я должен получить сведения о пользователе по его id. Это HTTP-запрос, который приходит в мой уровень обработчика HTTP, я использую идентификатор, который я получаю из запроса, посылаю сообщение актору, который затем обращается к службе базы данных, чтобы получить пользователя. ...

Я хочу протестировать некоторые функции Akka streams, такие как conflate. Для этого мне нужно построить источник, на который не влияет противодавление в рамках простого юнит-теста. Наивные попытки вроде Source.tick(1.milli, 1.milli, "tick").map(_ => Random.nextDouble()) Не работают из-за противодавлени...

Проект APARAPI описывает себя следующим образом: Aparapi позволяет разработчикам Java использовать преимущества вычислительной мощности GPU и устройств APU, выполняя фрагменты параллельного кода данных на GPU, а не ограничиваясь локальным процессором. Он делает это путем преобразования байт-кода Java в O...

Я недавно смотрел на Акку, и это довольно впечатляет. Похоже, что у него есть большинство убийственных функций erlang - прозрачность местоположения, иерархия надзора и многое другое. Есть ли у Эрланга какие-то особенности, которых нет у акки?...

Я работал с Node.js на некоторое время и считаю себя довольно хорошо с Java. Но я только что обнаружил Akka и сразу же заинтересовался его картины актер (насколько я понимаю). это было мое понимание, что узел отлично справляется со многими одновременными оперативный. Я предполагаю, что хороший веб-сервис...

Я обнаружил, что есть также модель акка-актера, поэтому мне интересно, в чем разница между актером акки и моделью актера скалы?...

Я новичок в рамках Akka, и я создаю приложение HTTP-сервера поверх Netty + Akka. моя идея до сих пор заключается в создании актера для каждого типа запроса. Например, у меня был бы актер для сообщения в /my-resource и другой актер для получения /my-resource. где я запутался, как я должен идти о создании акт...

Акка 2.X требует много команд для ссылки ActorSystem. Итак, чтобы создать экземпляр актера MyActor вы можете сказать: val system = ActorSystem() val myActor = system.actorOf(Props[MyActor]) из-за частой необходимости ActorSystem: многие примеры кода опускают создание из кода и предполагают, что читатель з...