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 refatorar esse código usando fluxos akka.
A idéia é manter o canal aberto para usá-lo mais tarde. No playframework 2.5.x, a documentação diz que você precisa usar fluxos akka, mas não diz nada sobre como obter esse exemplo. Alguém pode me ajudar? import play.api.mvc._ import ...
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 ...
Como usar um SourceQueue do Akka Streams com o PlayFramework
Eu gostaria de usar um SourceQueue para enviar elementos dinamicamente para uma fonte do Akka Stream. O controlador Play precisa de uma fonte para transmitir um resultado usando ochuncked método. Como o Play usa seu próprio Akka Stream Sink sob o ...
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 ...
Como forneço um valor implícito para um akka.stream.Materializer ao enviar um FakeRequest?
Estou tentando entender os erros que estou vendo abaixo e aprendendo a corrigi-los. could not find implicit value for parameter materializer: akka.Stream.Materializer val fut: Future[Result] = action.apply(fakeRequest).run ^ not enough arguments ...
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 ...