Resultados de la búsqueda a petición "akka-stream"
¿Cómo limitar un Akka Stream para ejecutar y enviar un mensaje solo una vez por segundo?
Tengo un Akka Stream y quiero que el flujo envíe mensajes de descarga aproximadamente cada segundo. Intenté dos formas de resolver este problema, la primera fue hacer que el productor al comienzo de la transmisión solo enviara mensajes una vez ...
¿Cómo funciona akka stream throttle?
def throttle(elements: Int, per: FiniteDuration, maximumBurst: Int, mode: ThrottleMode): Repr[Out]HacemaximumBurst significa la cantidad de elementos que se pueden procesar al mismo tiempo?
Websocket Proxy usando Play 2.6 y transmisiones de akka
Estoy tratando de crear un Proxy simple para conexiones Websocket usando Play y akka streams. El flujo de tráfico es así: (Client) request -> -> request (Server) Proxy (Client) response <- <- response (Server)Se me ocurrió el siguiente código ...
Forma adecuada de detener Akka Streams con la condición
He estado usando exitosamenteFileIO [http://doc.akka.io/api/akka/2.4/?_ga=1.140568374.588201913.1464855311#akka.stream.scaladsl.FileIO$] para transmitir el contenido de un archivo, calcule algunas transformaciones para cada línea y agregue / ...
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 ...
Acceso al ActorRef subyacente de una fuente de flujo de akka creada por Source.actorRef
Estoy tratando de usar elSource.actorRef [http://doc.akka.io/api/akka-stream-and-http-experimental/1.0-RC3/?_ga=1.155309435.1917589872.1429296441#akka.stream.scaladsl.Source$] método para crear ...
¿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 ...
Cómo usar el mensaje de envío websocket del cliente Akka-HTTP
Estoy intentando websocket del lado del cliente siguiendo el documento en webSocketClientFlow [http://doc.akka.io/docs/akka/2.4/scala/http/client-side/websocket-support.html#webSocketClientFlow] . el código de muestra es: import ...
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. ...
¿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 ...