Resultados de la búsqueda a petición "akka-stream"

0 la respuesta

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 ...

1 la respuesta

¿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?

1 la respuesta

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 ...

1 la respuesta

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 / ...

1 la respuesta

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í ...

2 la respuesta

¿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 ...

1 la respuesta

akka-stream: cómo tratar el último elemento de una secuencia de manera diferente en un flujo / gráfico

Estoy tratando de implementar un Akka StreamsFlow eso convertirá una secuencia de objetos JSON en una secuencia de una sola matriz de objetos JSON. Puedo usarConcat para agregar un "[" antes y "]" después, así comoZip para insertar comas entre ...

1 la respuesta

¿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 ...

2 la respuesta

Cómo usar un SourceQueue de Akka Streams con PlayFramework

Me gustaría usar un SourceQueue para insertar elementos dinámicamente en una fuente de Akka Stream. El controlador de Play necesita una fuente para poder transmitir un resultado usando elchuncked método. Como Play usa su propio Akka Stream Sink ...

3 la respuesta

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 ...