Resultados de la búsqueda a petición "akka"
Akka / Java getContext (). ¿Se convierte en parámetro?
En Akka / Scala, uno puede pasar parámetros a la función de recepción personalizada, por lo que es posible pasar todo el estado del actor a través de parámet...
Akka Actor cómo procesar solo el último mensaje.
Digamos que estoy enviando mensajes a un Actor, cuando está procesando un mensaje, pueden aparecer varios mensajes más. Ahora, cuando esté listo para procesa...
¿Cómo agrego dinámicamente el origen al gráfico existente?
¿Qué puede ser una alternativa para cambiar dinámicamente el gráfico en ejecución? Aquí está mi situación. Tengo un gráfico que ingiere artículos en DB. Los artículos provienen de 3 complementos en diferentes formatos. Así tengo varios ...
Akka Flow se bloquea al realizar solicitudes http a través del grupo de conexiones
Estoy usando Akka 2.4.4 e intento moverme de Apache HttpAsyncClient (sin éxito). A continuación se muestra la versión simplificada del código que uso en mi proyecto. El problema es que se cuelga si envío más de 1-3 solicitudes al flujo. ...
Servidor Akka HTTPS (SSL) con ssl-conf
Versión Akka: Akka 2.4.7 [https://github.com/akka/akka/tree/v2.4.7]Características de Akka: Soporte de servidor HTTPS [http://doc.akka.io/docs/akka/2.4.7/scala/http/server-side-https-support.html] Ssl-config de Typesafe ...
Llamar a un método en juego WebSocket en Scala
Soy nuevo en scala, Play framework y Akka. Tengo una función definida como def socket = WebSocket.accept[String, String] { request => ActorFlow.actorRef(out => MyWebSocketActor.props(out)) }Esto quiero llamar desde otra clase. No tengo claro ...
¿Cómo proporciono un valor implícito para un akka.stream.Materializer cuando envío un FakeRequest?
Intento dar sentido a los errores que veo a continuación y aprender a solucionarlos. could not find implicit value for parameter materializer: akka.Stream.Materializer val fut: Future[Result] = action.apply(fakeRequest).run ^ not enough ...
Cómo enviar un mensaje en una secuencia reactiva de un suscriptor a un editor en una conexión de socket web
Mi aplicación tiene una interfaz Akka-Websocket. El portal web consta de un actor suscriptor y un actor editor. El suscriptor maneja los comandos enviándolos al actor correspondiente. El editor escucha en la secuencia del evento y publica ...