Suchergebnisse für Anfrage "future"
Ist es möglich, einen Rückruf zu installieren, nachdem die Anforderungsverarbeitung in Spray abgeschlossen ist?
Ich versuche, große temporäre Dateien von Spray bereitzustellen. Ich muss diese Dateien löschen, sobald die HTTP-Anforderung abgeschlossen ist. Ich konnte bisher keinen Weg finden, dies zu tun ... Ich verwende Code ähnlich ...
Verwandeln Sie Java Future in eine CompletableFuture
Java 8 stellt vorCompletableFuture, eine neue Implementierung von Future, die komponierbar ist (enthält eine Reihe von thenXxx-Methoden). Ich möchte dies ausschließlich verwenden, aber viele der Bibliotheken, die ich verwenden möchte, geben nur ...
Daten aus einer Zukunft in Scala holen
Ich habe eineFuture[List[Person]]Und ich möchte das bekommenList[Person] davon. Wie kann ich es tun ? import scala.concurrent.Future val futPersons : Future[List[Person]] = ....
Skala-Weg, um mit Zuständen in Vorstellungen umzugehen?
Ich versuche, eine übersichtliche Konstruktion mit Verständnis für Geschäftslogik zu erstellen, die auf Futures basiert. Hier ist ein Beispiel, das ein Arbeitsbeispiel enthält, das auf der Ausnahmebehandlung basiert: (for { // find the user by ...
Umgang mit gescheiterten Futures
In Play Framework 2.3 kann eine Aktion ein Ergebnis eines erfolgreichen zukünftigen Aufrufs wie folgt erzeugen: def index = Action.async { val futureInt = scala.concurrent.Future { intensiveComputation() } futureInt.map(i => Ok("Got result: " + ...
Wie man eine Methode immer wieder aufruft, bis sie einen `Future` -Wert zurückgibt, der` None` enthält
Gibt eine Methode zurück, die ein @ zurückgibFuture so was.. def remove(id: String): Future[Option[User]] = Future { // removes and returns the user identified by `id` } ... wie rufe ich es immer wieder auf, bis es ein @ zurückgiFuture Wert ...
Gibt es sequentielle Future.find?
Ich habe eine Nebenwirkung, def f(): Future[Int] = { val n = Random.nextInt() println(s"Generated $n") Future(n) }und ich möchte es wiederholt ausführen, bis das Prädikat true zurückgibt. def success(n: Int): Boolean = n % 2 == 0Mein Plan ist ...
Wie verwende ich CompletableFuture.thenComposeAsync ()?
Gegeben 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: " ...
Sind Futures in Scala wirklich funktionsfähig?
Ich lese diesen BlogPos [http://futurice.com/blog/an-example-of-functional-design] das behauptetFutures sind nicht "funktional", da sie nur Wrapper von @ si Nebenwirkungen Berechnungen. Sie enthalten beispielsweise RPC-Aufrufe, HTTP-Anforderungen ...
Misserfolg in der Zukunft von Scala für das Verständnis
Ich habe drei aufeinanderfolgende Futures und verwende zum Verständnis wie dieses val comF = for { f1 <- future1 f2 <- future2 f3 <- future3 } yield { // something } comF onSuccess { } comF onFailure { // ---------------- Here is the problem ...