Resultados da pesquisa a pedido "akka"
Cliente Akka TCP: como enviar uma mensagem pelo TCP usando o akka actor
Quero enviar mensagens de texto por TCP. Bem fácil. Eu quero fazer isso com akka. Eu li este artigo sobre o akka IO: http://doc.akka.io/docs/akka/snapshot/scala/io-tcp.html [http://doc.akka.io/docs/akka/snapshot/scala/io-tcp.html] O artigo ...
Akka-http: como obter um cabeçalho personalizado a partir de uma solicitação?
Envio os seguintes cabeçalhos em uma solicitação para minha akka-http api:"Content-type": "application/json", "Accept": "application/json", "AppId": "some_id". Como obtenho o cabeçalho personalizado "AppId" na minha rota akka-http? (get & ...
Como um log de solicitações do cliente HTTP Akka
Preciso registrar as solicitações do cliente http akka, bem como suas respostas. Embora pareça haver uma dica da API para registrar essas solicitações, não há documentação clara sobre como isso deve ser feito. Minha abordagem foi criar ...
akka-http: Como definir cabeçalhos de resposta
Eu tenho uma rota da seguinte maneira: val route = { logRequestResult("user-service") { pathPrefix("user") { get { respondWithHeader(RawHeader("Content-Type", "application/json")) { parameters("firstName".?, "lastName".?).as(Name) { name => ...
akka HttpResponse lê o corpo como escala de String
Então, eu tenho uma função com esta assinatura (akka.http.model.HttpResponse): def apply(query: Seq[(String, String)], accept: String): HttpResponseEu simplesmente recebo um valor em um teste como: val resp = TagAPI(Seq.empty[(String, String)], ...
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 ...
Diferença entre classe de caso e objeto de caso?
Estou aprendendo Scala e Akka e em minha pesquisa recente por umsolução [https://stackoverflow.com/questions/22770927/waiting-for-multiple-results-in-akka] , Eu encontrei algo como case class TotalTaxResult(taxAmount:Double) case object ...
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 ...
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: ...
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 ...