Resultados de la búsqueda a petición "akka"
Cliente Akka TCP: ¿Cómo puedo enviar un mensaje a través de TCP usando akka actor?
Quiero enviar mensajes de texto a través de TCP. Muy fácil. Quiero hacerlo con akka. Leí este artículo sobre akka IO: http://doc.akka.io/docs/akka/snapshot/scala/io-tcp.html [http://doc.akka.io/docs/akka/snapshot/scala/io-tcp.html] El artículo ...
Akka-http: ¿Cómo obtener un encabezado personalizado de una solicitud?
Envío los siguientes encabezados en una solicitud a mi akka-http api:"Content-type": "application/json", "Accept": "application/json", "AppId": "some_id". ¿Cómo obtengo el encabezado personalizado "AppId" en mi ruta akka-http? (get & ...
¿Cómo se registran las solicitudes de un cliente HTTP de Akka?
Necesito registrar las solicitudes de clientes http akka, así como sus respuestas. Si bien parece haber un indicio de API para registrar estas solicitudes, no existe una documentación clara sobre cómo debe hacerse. Mi enfoque ha sido crear una ...
akka-http: Cómo configurar encabezados de respuesta
Tengo una ruta de la siguiente manera: val route = { logRequestResult("user-service") { pathPrefix("user") { get { respondWithHeader(RawHeader("Content-Type", "application/json")) { parameters("firstName".?, "lastName".?).as(Name) { name => ...
akka HttpResponse lee el cuerpo como String scala
Entonces tengo una función con esta firma (akka.http.model.HttpResponse): def apply(query: Seq[(String, String)], accept: String): HttpResponseSimplemente obtengo un valor en una prueba como: val resp = TagAPI(Seq.empty[(String, String)], ...
Supervisión personalizada. Decid no captura la excepción producida por ActorPublisher
Estoy construyendo una biblioteca que será utilizada por terceros. En uno de mis métodos vuelvoStream[Item] que se genera de forma asíncrona a partir del resultado de una llamada API REST paginada. Estoy usando mi modificación ...
¿Diferencia entre clase de caso y objeto de caso?
Estoy aprendiendo Scala y Akka y en mi reciente búsqueda de unsolución [https://stackoverflow.com/questions/22770927/waiting-for-multiple-results-in-akka] Encontré algo como case class TotalTaxResult(taxAmount:Double) case object ...
¿Cómo hace spray.routing.HttpService para enviar solicitudes?
Descargo de responsabilidad: no tengo experiencia en scala por ahora, por lo que mi pregunta está relacionada con lo más básico. Considere el siguiente ejemplo (puede estar incompleto): import akka.actor.{ActorSystem, Props} import akka.io.IO ...
¿Cómo funciona la API de Acción asíncrona en Play Framework 2.2.x para Scala?
Estaba tratando de crear una API asíncrona. Pero la respuesta muestra ejecución secuencial. Pasos realizados: abre la url en dos pestañas de cromo. Y golpearlos uno tras otro rápidamente. url ex: -localhost:9000/getStar. Pero el registro de ...
Obtenga todo el cuerpo HttpResponse como una cadena con Akka-Streams HTTP
Estoy tratando de entender cómo usar el nuevoakka.http biblioteca. Me gustaría enviar una solicitud http a un servidor y leer todo el cuerpo de la respuesta como una sola cadena para producir unSource[String,?]. Aquí está la mejor solución que ...