future

6calore

1risposta

Utilizzando mapTo con i futures a Akka/Scala

Recentemente ho iniziato la codifica con Akka/Scala, e ho incontrato il seguente problema: Con una conversione implicita nel campo di applicazione, come ad esempio: implicit def convertTypeAtoTypeX(a:

7calore

3risposta

convertiamo il futuro di Scala nel futuro di Twitter

Uso Finagle come un server Web che voglio restituire a Scala-Futures dalla logica dell'applicazione. Come convertire scala.concurrent.Future in com.twitter.util.Future, ovviamente in modo non bloccant

8calore

1risposta

Interfaccia Spark Async per Fold, Reduce, Aggregate?

Nel API ufficiali Spark RDD: https://spark.apache.org/docs/2.1.0/api/java/org/apache/spark/rdd/AsyncRDDActions.html conteggio, raccogliere, foreach, e prendere tutti hanno le varianti asincrone che re

7calore

2risposta

Scala: ignora il valore di ritorno futuro, ma li tiene in catena

Come devo scrivere il codice, quando non mi interessa il valore restituito. Esempio: for { a <- getA // I do not care about a, but I need to wait for the future to finish b <- getB } yield

8calore

2risposta

Eccezione time-volley Android durante l'utilizzo di RequestFuture.get()

Nel mio frammento, sto tentando di utilizzare il DB del film aperto di TMDB per ottenere dettagli sui filmati "In riproduzione". Se utilizzo il metodo RequestFuture.get (time, TimeUnit) per eseguire q

12calore

1risposta

Promessa/futuro C++: quale ritorno da una funzione?

Ho una funzione che restituisce un riferimento a uno std :: promessa: std::shared_ptr<std::promise<void>> play(); (Maggiori informazioni:. La funzione di riprodurre supporti su alcuni dispositivi, e

16calore

2risposta

Akka vs Java 7 Futures

Sto cercando di capire quando utilizzare Akka Futures e ho trovato this article un po 'più utile rispetto ai documenti Akka principali. Quindi sembra che Akka Futures faccia esattamente la stessa cosa

10calore

1risposta

Perché il eThen of Future non concatena il risultato?

Il significato andThen che ho appreso da questo answer è un compositore di funzioni. dire che f andThen g andThen h sarà pari a h(g(f(x))) Ciò implica la h function riceveranno input da g(f(x)) Ma

5calore

1risposta

Annulla attività su timeout in RxJava

Sto sperimentando con RxJava e la classe CompletableFuture di Java 8 e non riesco a capire come gestire le condizioni di timeout. import static net.javacrumbs.futureconverter.java8rx.FutureConverter.t

9calore

2risposta

I futures sono eseguiti su un singolo thread? (Scala)

Utilizzando il contesto di esecuzione implicito predefinito in Scala, ciascun nuovo futuro verrà calcolato su un singolo thread dedicato o il calcolo verrà diviso e distribuito a più thread nel pool d