Resultados de la búsqueda a petición "akka"
¿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 ...
obteniendo el estado -1 en lugar de 401 Angularjs
Estoy tratando de obtener una respuesta del servidor. La función se ve así: function getOverview() { var req = { method: 'GET', url: base, headers: { 'authorization': 'Bearer ' + GottenTokens.getSessionToken() } }; return $http(req).then( ...
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 ...
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 ...
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. ...
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 ...
¿Por qué Spark 1.6 no usa Akka?
Cuando leo el código fuente de spark-1.6 delMaestro [https://github.com/apache/spark/blob/cf2e9da612397233ae7bca0e9ce57309f16226b5/core/src/main/scala/org/apache/spark/deploy/master/Master.scala] En la clase, el método ReceiveAndReply parece no ...
Llamar a un método en juego WebSocket en Scala
Soy nuevo en scala, Play framework y Akka. Tengo una función definida como def socket = WebSocket.accept[String, String] { request => ActorFlow.actorRef(out => MyWebSocketActor.props(out)) }Esto quiero llamar desde otra clase. No tengo claro ...
Java Spring como cliente para llamada HTTP REST basada en Akka
Tengo que llamar a este servicio REST escrito enscala-akka proyecto dejava-spring. mi servicio scala REST es como val route = post { path("notification" / "signUp"){ headerValueByName("App_Key") { app_key => { handleWith { requestParameters: ...
Consume el flujo TCP y redirige a otro sumidero (con Akka Streams)
Intento redirigir / reenviar una secuencia TCP a otro sumidero con Akka 2.4.3. El programa debe abrir un socket de servidor, escuchar las conexiones entrantes y luego consumir el flujo tcp. Nuestro remitente no espera / acepta respuestas de ...