Resultados de la búsqueda a petición "akka-stream"
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 ...
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 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?
Cómo hacer una llamada POST al servidor autocertificado con akka-http
Tengo una topología de akka-streams, donde hago una llamada POST usando akka-http. Recibo el siguiente error cuando llego a la solicitud de publicación en un servidor no seguro (que tiene certificados autofirmados). Es un servidor interno, así ...
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 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!
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 ...
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 ...
¿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 ...
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 ...