Resultados da pesquisa a pedido "future"
Obtendo dados de um futuro em Scala
Eu tenho umFuture[List[Person]][1] e eu quero pegar oList[Person] a partir dele. Como eu posso fazer isso ? import scala.concurrent.Future val futPersons : Future[List[Person]] = ....
Scala-maneira de lidar com as condições de compreensão?
Estou tentando criar uma construção elegante com compreensão da lógica de negócios baseada em futuros. Aqui está um exemplo que contém um exemplo de trabalho baseado no tratamento de exceções: (for { // find the user by id, findUser(id) returns ...
Lidar com futuros falidos
No Play Framework 2.3, uma ação pode produzir um resultado de uma chamada futura bem-sucedida como esta: def index = Action.async { val futureInt = scala.concurrent.Future { intensiveComputation() } futureInt.map(i => Ok("Got result: " + i)) ...
Existe Future.find seqüencial?
Eu tenho alguma função com efeito colateral, def f(): Future[Int] = { val n = Random.nextInt() println(s"Generated $n") Future(n) }e quero executá-lo repetidamente até que o predicado retorne verdadeiro. def success(n: Int): Boolean = n % 2 == ...
Como usar CompletableFuture.thenComposeAsync ()?
Dado: public class Test { public static void main(String[] args) { int nThreads = 1; Executor e = Executors.newFixedThreadPool(nThreads); CompletableFuture.runAsync(() -> { System.out.println("Task 1. Thread: " + Thread.currentThread().getId()); ...
Como invocar um método repetidamente até retornar um valor `Futuro` contendo` Nenhum`
Dado um método que retorna umFuture como isso... def remove(id: String): Future[Option[User]] = Future { // removes and returns the user identified by `id` }... como invocá-lo repetidamente até que retorne umFuture valor ...
Os futuros em Scala são realmente funcionais?
Eu estou lendo este blogpostar [http://futurice.com/blog/an-example-of-functional-design]que afirmaFutures não são "funcionais", pois são apenas invólucros decom efeito colateral cálculos. Por exemplo, eles contêm chamadas RPC, solicitações HTTP, ...
falha no futuro da Scala para compreensão
Eu tenho três futuros sequenciais e uso no para compreensão como esta val comF = for { f1 <- future1 f2 <- future2 f3 <- future3 } yield { // something } comF onSuccess { } comF onFailure { // ---------------- Here is the problem ...
Usando futuros e Thread.sleep
Ao executar esse código scala, não tenho saída no console. (Eu realmente não entendo o que está acontecendo) Se eu removerConsole.println("Console.println OK!") => tudo parece bem. Se eu removerThread.sleep(2000) => tudo parece bem. Você tem ...
Como compor Observables para evitar os retornos de chamada aninhados e dependentes?
Noeste blog [https://web.archive.org/web/20150712091623/http://benjchristensen.com:80/2013/05/01/functional-reactive-in-the-netflix-api-with-rxjava/] , ele dáesta [https://gist.github.com/benjchristensen/4677544](copie / cole o código a seguir) ...