akka

2зной

2ответ

У меня есть метод, как это: def myFuture: Future[Either[MyLeft, MyRight]] = Future { . . . } Если я хочу, чтобы трубы результат, я использую: Patterns.pipe(myFuture,ec).to(destinationActor) Но

0зной

1ответ

Как остановить всех актеров и дождаться их окончания?

Я реализую модульные тесты для моего проекта Akka. Чтобы избежать InvalidActorNameException и т. Д., Я хочу, чтобы все участники, которые были созданы в рамках одного модульного теста, были остановлен

-1зной

1ответ

Как загрузить двухуровневую маршрутизацию в High Server Http Akka с помощью Java?

Я пытаюсь работать с akka Http с Java. Я хотел бы загрузить маршрут, который выглядит следующим образом: hello/world На моем HttpApp, я попробовал: return route( path("hello/world",() ->

0зной

1ответ

Akka поток от ftp, строка за строкой

Я пытаюсь прочитать файл с ftp-сервера, используя потоки alpakka и scala. Тип, который я получаю от Ftp.fromPath(...), составляет Source[ByteString, Future[IOResult]]. Я бы хотел прочитать файл строки

1зной

1ответ

замена базы данных sql с использованием akka-persistence - почему этого не происходит?

Есть способы замены баз данных SQL в Haskell, Clojure: http://www.datomic.com/ (Clojure) https://github.com/dmbarbour/haskell-vcache https://hackage.haskell.org/package/acid-state Однако я не могу най

0зной

2ответ

Как справляться с ошибками, когда один из участников роутера выдает исключение

Скажите, что у меня есть отправитель электронной почты, который отвечает за отправку писем. Я хочу ограничить # участников, созданных для отправки электронных писем, поэтому я создал маршрутизатор. cl

3зной

3ответ

Akka - худшее исполнение с большим количеством актеров

Я пытаюсь провести параллельное программирование с помощью Scala и Akka, для которых я новичок. У меня довольно простое приложение Monte Carlo Pi (аппроксимирует pi по кругу), который я построил на не

0зной

1ответ

Когда должен быть создан Актер в системе Актера или Контексте Актера?

В Акке, когда я должен создать актера, используя system.actorOf() vs context.actorOf()? Я знаю, что context.actorOf() создает дочернего актера, но когда один актер должен быть ребенком другого и верхн

2зной

1ответ

Akka cluster: почему я не получаю событие UnreachableMember, когда участник отмечен как недоступный?

Я хотел бы изменить поведение узла кластера, когда другой узел недоступен. Вот почему я хочу делать ставки, когда другой участник недоступен. Когда член недостижим, я могу видеть его в журналах: [warn