Resultados de la búsqueda a petición "future"
Cómo invocar un método una y otra vez hasta que devuelva un valor `Futuro` que contenga` Ninguno`
Dado un método que devuelve unFuture Me gusta esto... def remove(id: String): Future[Option[User]] = Future { // removes and returns the user identified by `id` }... cómo lo invoco una y otra vez hasta que devuelva unFuture valor que ...
Tratar con futuros fallidos
En Play Framework 2.3, una acción puede producir un resultado de una llamada futura exitosa como esta: def index = Action.async { val futureInt = scala.concurrent.Future { intensiveComputation() } futureInt.map(i => Ok("Got result: " + i)) ...
¿Escala para manejar las condiciones en las comprensiones?
Estoy tratando de crear una construcción ordenada con comprensión de la lógica empresarial basada en futuros. Aquí hay una muestra que contiene un ejemplo de trabajo basado en el manejo de excepciones: (for { // find the user by id, findUser(id) ...
Obtener datos de un futuro en Scala
Tengo unaFuture[List[Person]][1] y quiero obtener elList[Person] de eso. Cómo puedo hacerlo ? import scala.concurrent.Future val futPersons : Future[List[Person]] = ....
Transforma el futuro de Java en un futuro completable
Java 8 presentaCompletableFuture, una nueva implementación de Future que es componible (incluye un montón de métodos thenXxx). Me gustaría usar esto exclusivamente, pero muchas de las bibliotecas que quiero usar solo devuelven ...
¿El objeto futuro devuelto por executeorService.submit (Runnable) tiene alguna referencia al objeto ejecutable?
Supongamos que tenemos el siguiente código: List<Future<?>> runningTasks; ExecutorService executor; ... void executeTask(Runnable task){ runningTasks.add(executor.submit(task)); }Mis preguntas son: HacerunningTasks mantener una referencia a ...
¿Es posible instalar una devolución de llamada después de que el procesamiento de la solicitud haya finalizado en Spray?
Estoy tratando de servir archivos temporales grandes de Spray. Necesito eliminar esos archivos una vez que se complete la solicitud HTTP. No pude encontrar una manera de hacer esto hasta ahora ... Estoy usando un código similar ...
Usando futuros en los actores de Akka
Estoy empezando a aprender Akka Actors en Scala. Tengo entendido que los mensajes recibidos por un actor se ponen en cola en el buzón de un actor y se procesan uno por uno. Al procesar los mensajes uno a la vez, se mitigan los problemas de ...
¿Por qué esto no está compilando? (RValue como argumentos CTOR de hilo)
Hola, aquí hay un código de prueba que escribí en MSVC12. ¿Alguien podría decirme por qué std :: move cuando paso parámetros al hilo no está convirtiendo las variables a referencias RValue? Y lo que debo hacer. ¡Gracias! ///some arbitrary long ...
Secuenciando 'Future`s con tiempo de espera
Utilicé elTimeoutScheduler introducido enScala Futures: ¿tiempo de espera incorporado? [https://stackoverflow.com/questions/16304471/scala-futures-built-in-timeout]. Sin embargo, ahora mi programa no termina como antes ...