Resultados da pesquisa a pedido "akka"
Futuro da Akka - Paralelo versus Concorrente?
Do bem escritoAkka Simultaneidade [http://www.artima.com/shop/akka_concurrency]: [/imgs/xFnqg.png] ComoCompreendo, o diagrama indica, ambosnumSummer echarConcat será executado no mesmo segmento. É possível executar cadaFuture em paralelo, ou ...
Como limitar um Akka Stream para executar e enviar uma mensagem apenas uma vez por segundo?
Eu tenho um Akka Stream e quero que ele envie mensagens no fluxo aproximadamente a cada segundo. Tentei duas maneiras de resolver esse problema: a primeira maneira era fazer o produtor no início do fluxo enviar mensagens apenas uma vez a cada ...
obtendo status -1 em vez de 401 Angularjs
Estou tentando obter uma resposta do servidor. A função parece assim: function getOverview() { var req = { method: 'GET', url: base, headers: { 'authorization': 'Bearer ' + GottenTokens.getSessionToken() } }; return $http(req).then( function ...
Akka Stream + Akka Http - Obter solicitação por erro
Eu tenho o seguinte fluxo que funciona muito bem: source .map(x => HttpRequest(uri = x.rawRequest)) .via(Http().outgoingConnection(host, port)) .to(Sink.actorRef(myActor, IsDone)) .run()e um agente simples para lidar com o status da resposta e a ...
Como enviar uma mensagem em um fluxo reativo de um assinante para um editor em uma conexão de soquete da Web
Meu aplicativo possui uma interface Akka-Websocket. O soquete da Web consiste em um ator-assinante e um editor de ator. O assinante manipula comandos, enviando-os para o ator correspondente. O editor escuta no fluxo de eventos e publica ...
O Akka Flow trava ao fazer solicitações HTTP via pool de conexão
Estou usando o Akka 2.4.4 e tentando sair do Apache HttpAsyncClient (sem êxito). Abaixo está a versão simplificada do código que eu uso no meu projeto. O problema é que ele trava se eu enviar mais de 1 a 3 solicitações para o fluxo. Até agora, ...
akka-stream - Como tratar o último elemento de um fluxo de maneira diferente em um Flow / Graph
Estou tentando implementar um Akka StreamsFlow que converterá um fluxo de objetos JSON em um fluxo de uma única matriz de objetos JSON. Eu posso usarConcat para adicionar um "[" antes e "]" depois, bem comoZip para inserir vírgulas entre os ...
Por que o Spark 1.6 não usa Akka?
Quando leio o código fonte do spark-1.6 domestre [https://github.com/apache/spark/blob/cf2e9da612397233ae7bca0e9ce57309f16226b5/core/src/main/scala/org/apache/spark/deploy/master/Master.scala] classe, o método receiveAndReply parece não estar ...
Chamando um método no WebSocket do jogo no Scala
Eu sou novo no scala, Play framework e Akka. Eu tenho a função definida como def socket = WebSocket.accept[String, String] { request => ActorFlow.actorRef(out => MyWebSocketActor.props(out)) }Isso eu quero chamar de outra classe. Não sei como ...
Java Spring como um cliente para chamada HTTP REST baseada em Akka
eu tenho que chamar esse serviço REST escrito emscala-akka projeto dejava-spring. meu serviço REST scala é como val route = post { path("notification" / "signUp"){ headerValueByName("App_Key") { app_key => { handleWith { requestParameters: ...