Resultados da pesquisa a pedido "akka"
Como testo um ator da Akka que envia uma mensagem para outro ator?
Estou usando o ScalaTest com o Akka TestKit para escrever testes de unidade e integração para um ator que eu codifiquei para simplesmente enviar uma mensagem para outro ator sem alterar nenhum estado interno. Veja isso por exemplo: class MyActor ...
Acessando o ActorRef subjacente de uma fonte de fluxo akka criada por Source.actorRef
Estou tentando usar oSource.actorRef [http://doc.akka.io/api/akka-stream-and-http-experimental/1.0-RC3/?_ga=1.155309435.1917589872.1429296441#akka.stream.scaladsl.Source$] método para criar ...
Akka moderno DI com Guice
Java 8, Guice 4.0 e Akka 2.3.9 aqui. Estou tentando descobrir como anotar minhas classes de ator com estilo JSR330@Inject anotações e, em seguida, conecte-as através do Guice. Mas literalmente todos os artigos que eu li (alguns exemplos abaixo) ...
Akka consolida solicitações simultâneas de banco de dados
Quero poder fazer solicitações simultâneas para vários repositórios de dados e consolidar os resultados. Estou tentando entender se minha abordagem é válida ou se existe uma maneira melhor de abordar esse problema. Definitivamente, sou novo na ...
Nenhuma configuração encontrada para a chave 'akka.version'
Estou aprendendo akka-remoting e é assim que meu projeto fica A estrutura do projeto parece project/pom.xml ...
Como criar uma fonte que possa receber elementos posteriormente por meio de uma chamada de método?
Eu gostaria de criar umSource e depois empurre elementos nele, como em: val src = ... // create the Source here // and then, do something like this pushElement(x1, src) pushElement(x2, src)Qual é a maneira recomendada de fazer isso? Obrigado!
Por que a transmissão por faísca não funciona bem quando uso o App extends?
O primeiro código lança uma exceção de ponteiro nulo. object TryBroadcast extends App{ val conf = new SparkConf().setAppName("o_o") val sc = new SparkContext(conf) val sample = sc.parallelize(1 to 1024) val bro = sc.broadcast(6666) val broSample ...
Obter todo o corpo do HttpResponse como uma String com o Akka-Streams HTTP
Estou tentando entender como usar o novoakka.http biblioteca. Gostaria de enviar uma solicitação http para um servidor e ler todo o corpo da resposta como uma única String para produzir umSource[String,?]. Aqui está a melhor solução que consegui ...
Como a API de ação assíncrona funciona no jogo framework 2.2.x para scala?
Eu estava tentando criar API assíncrona. Mas a resposta mostra execução sequencial. Etapas concluídas: abra o URL em duas guias do chrome. E bata neles um após o outro rapidamente. URL ex: -localhost:9000/getStar. Mas o log de execução é como: ...
Como o spray.routing.HttpService envia solicitações?
Isenção de responsabilidade: por enquanto, não tenho experiência em scala, portanto, minha pergunta está relacionada a muito básico. Considere o seguinte exemplo (pode estar incompleto): import akka.actor.{ActorSystem, Props} import akka.io.IO ...