Resultados de la búsqueda a petición "akka-stream"
¿Por qué el ciclo de transmisiones de Akka no termina en este gráfico?
Me gustaría crear un gráfico que se repita n veces antes de hundirse. Acabo de crear esta muestra que cumple mis requisitos, pero no termina después de hundirse y realmente no entiendo por qué. ¿Alguien puede iluminarme? Gracias. import ...
¿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 se usan las secuencias reactivas en Slick para insertar datos?
EnDocumentación de Slick [http://slick.typesafe.com/doc/3.1.1/dbio.html#streaming]Se presentan ejemplos de uso de flujos reactivos solo para leer datos como un medio de un publicador de bases de datos. Pero, ¿qué sucede cuando desea utilizar su ...
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 ...
¿Cómo crear una fuente que pueda recibir elementos más tarde a través de una llamada al método?
Me gustaría crear unSource y luego empujar elementos sobre él, como en: val src = ... // create the Source here // and then, do something like this pushElement(x1, src) pushElement(x2, src)cual es la manera recomendada para hacer esto? ¡Gracias!
¿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 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 ...
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 ...
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 / ...
Implementación de Akka-Stream más lenta que la implementación de subproceso único
ACTUALIZACIÓN DE 2015-10-30 basado en Roland Kuhn Awnser: Akka Streams está utilizando mensajes asíncronos que pasan entre actores para implementar etapas de procesamiento de flujo. El paso de datos a través de un límite asincrónico tiene una ...