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 ...
¿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 ...
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 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 ...
¿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?
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 / ...
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 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í ...
Akka Stream + Akka Http - Obtener solicitud por error
Tengo la siguiente secuencia que funciona bastante bien: source .map(x => HttpRequest(uri = x.rawRequest)) .via(Http().outgoingConnection(host, port)) .to(Sink.actorRef(myActor, IsDone)) .run()y un actor simple para manejar el estado de ...