Результаты поиска по запросу "akka"
Использовать поток TCP и перенаправить его на другой приемник (с помощью Akka Streams)
Я пытаюсь перенаправить / переслать поток TCP на другой Sink с Akka 2.4.3. Программа должна открыть сокет сервера, прослушать входящие соединения и затем исп...
Большое спасибо, пока!
ожусь в ситуации, когда я хочу, чтобы остановить / отменить работу Flink из кода. Это мой интеграционный тест, в котором я отправляю задание на мою работу Fl...
Карта исключений несостоявшегося будущего
Какой самый чистый способmap Exception неудачногоFuture в скале? Скажи, что у меня есть: import scala.concurrent._ import scala.concurrent.ExecutionContext.Implicits.global val f = Future { if(math.random < 0.5) 1 else throw new Exception("Oh ...
Пример актера DSL от Akka doc
Я пытаюсь реализовать пример Actor DSL из akk doc, но обнаружил ошибку, неоднозначные неявные значения: оба метода senderFromInbox в признаке Входящие типа (неявные входящие: akka.actor.ActorDSL.Inbox) akka.actor.ActorRef и значение self в ...
Тестирование актеров Akka, которые смешивают Stash с TestActorRef
Я столкнулся с проблемой с актером, который расширяет Stash и который прекрасно работает при создании его экземпляра с помощью actorOf в простой ActorSystem. Теперь я бы хотел написать несколько тестов для моих актеров, прежде чем использовать их ...
составление нескольких черт в akka актеров
Я создаю несколько черт, которые расширяют Актер. Затем я хочу создать актерский класс, который использует некоторые из этих черт. Однако я не уверен, как объединить методы receive из всех признаков в методе receive класса Actor. Черты: trait ...
только если вы хотите манипулировать сообщениями.
аюсь создать простой прокси для соединений Websocket, используя потоки Play и akka. Транспортный поток выглядит так:
Есть ли в Акке легковесные актеры?
Мой пример использования очень прост - для обмена несколькими (<100) сообщениями между двумя объектами акторы Scala отлично подходили для этой цели (легкий вес, отсутствие сложного управления жизненным циклом, запуск / завершение в ...
Пример создания конфигурации программно (это в Scala, но вы можете адаптировать ее для Java):
ли изменить или создать файл конфигурации из исходного кода. Я создаю клиент-серверную архитектуру с удаленным доступом. Что я хочу выполнить, так это возмож...