Resultados da pesquisa a pedido "akka-stream"
O Custom Supervision.Decider não captura a exceção produzida pelo ActorPublisher
Estou construindo uma biblioteca que será usada por terceiros. Em um dos meus métodos eu retornoStream[Item] que é gerado de forma assíncrona a partir do resultado da chamada da API REST paginada. Estou usando minha modificação ...
Por que o ciclo de fluxos Akka não termina neste gráfico?
Gostaria de criar um gráfico que faça um loop n vezes antes de afundar. Acabei de criar este exemplo que atende aos meus requisitos, mas não termina depois de afundar e realmente não entendo o porquê. Alguém pode me esclarecer? Obrigado. import ...
Implementação do Akka-Stream mais lenta que a implementação de thread único
ATUALIZAÇÃO DE 30-10-2015 baseado em Roland Kuhn Awnser: O Akka Streams está usando a passagem assíncrona de mensagens entre os atores para implementar estágios de processamento do fluxo. A passagem de dados através de um limite assíncrono tem ...
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 ...
Como os fluxos reativos são usados no Slick para inserir dados
NoDocumentação de Slick [http://slick.typesafe.com/doc/3.1.1/dbio.html#streaming]exemplos de uso de fluxos reativos são apresentados apenas para a leitura de dados como um meio de um DatabasePublisher. Mas o que acontece quando você deseja usar ...
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, ...