Resultados de la búsqueda a petición "akka"
¿Por qué la transmisión por chispa no funciona bien cuando uso la aplicación extendidas?
El primer código arroja una excepción de puntero nulo. object TryBroadcast extends App{ val conf = new SparkConf().setAppName("o_o") val sc = new SparkContext(conf) val sample = sc.parallelize(1 to 1024) val bro = sc.broadcast(6666) val ...
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 ...
¿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 ...
¿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 ...
¿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 ...
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 ...
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)], ...
¿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 => ...
¿Qué ThreadPool en Java debo usar?
Hay una gran cantidad de tareas. Cada tarea pertenece a un solo grupo. El requisito es que cada grupo de tareas debe ejecutarse en serie al igual que en un solo subproceso y el rendimiento debe maximizarse en un entorno de múltiples núcleos (o ...