Resultados de la búsqueda a petición "akka"
¿Es bueno o malo pasar ActorRef a otros actores?
Estoy tratando de averiguar si mi uso de pasar AkkaActorRef alrededor de otros actores no es un antipatrón. Tengo algunos actores en mi sistema. Algunos son de larga vida (restClientRouter,publisher) y algunos mueren después de haber hecho el ...
Socket TCP con SSL en Scala con Akka
Usando Scala 2.10 y Akka 2.3.4, he creado un servidor proxy simple que acepta conexiones TCP entrantes y luego envía esos mensajes a un servidor remoto. Las cosas funcionan con texto plano, pero estoy atascado con SSL. Brevemente, así es como ...
¿Cómo imprimir todos los actores en el sistema akka?
He creado el sistema akka. Supongamos que hay algunos actores en él. ¿Cómo puedo imprimir todos los actores del sistema akka con su camino? (para fines de depuración)
Fábrica de accesorios de actor de Akka
Akka y yo nos estamos conociendo. De :Akka 2.3.6 (actual) Actor Práctica recomendada [http://doc.akka.io/docs/akka/current/scala/actors.html#actorselection-scala#Props] Este es un ejemplo de actor llamado DemoActor: class ...
Play Framework como cliente de WebSocket
Estoy usando Play 2.3, estaba revisando la documentación para usar Akka como un servidor WebSocket. Sin embargo, en la documentación no indicaron si Play podría conectarse a los servidores WebSocket existentes. Básicamente, estoy interesado en ...
¿Qué significa "cerrar sobre el alcance / clase de cierre"?
La documentación de Akka documenta variantes peligrosas del usoProps: // NOT RECOMMENDED within another actor: // encourages to close over enclosing class val props7 = Props(new MyActor)Luego continúa diciendo: No se recomienda usar este método ...
Diferencia entre Actorref.tell e inbox.send en Akka
Así que comencé a aprender Akka y a probar los ejemplos en typesafe. Entonces la aplicación Hello Akka tiene el siguiente código: import akka.actor.{ ActorRef, ActorSystem, Props, Actor, Inbox } import scala.concurrent.duration._ case object ...
¿Scala ofrece IO sin bloqueo asíncrono cuando trabaja con archivos?
Estoy usando scala 2.10 y me pregunto si hay algún paquete que tenga IO asíncrono cuando trabajo con archivos. Hice un poco de búsqueda sobre este tema, pero encontré ejemplos como los siguientes val file = new File(canonicalFilename) val bw = ...
¿Cómo utilizar las secuencias reactivas para el procesamiento binario NIO?
¿Hay algunos ejemplos de código de usoorg.reactivestreams [http://www.reactive-streams.org/]bibliotecas para procesar grandes flujos de datos utilizando Java NIO (para un alto rendimiento)? Mi objetivo es el procesamiento distribuido, por lo que ...
Spray.io: no se puede compilar la especificación de prueba
Tengo el siguiente servicio: trait PingService extends MyHttpService { val pingRoutes = path("ping") { get { complete("message" -> "pong") } } }MyHttpServicees una clase personalizada que se extiendeHttpServicey solo contiene métodos de ...