Akka Futures guidance

Question

J'essaie d'utiliser Akka Futures pour lire plusieurs fichiers et passer chaque ligne à un appelable. Mes callables sont des analyseurs syntaxiques pour un fichier spécifique. Ainsi, people.txt peut remplir des objets de type Person. Chaque ligne peut contenir jusqu'à 50 champs nécessitant chacun une validation et des opérations pour remplir l'objet.

Je voudrais obtenir quelque chose comme Future <Iterable<Person>> dos, mais pas sûr que je reçois que de

BufferedReader reader = new BufferedReader(
    new InputStreamReader(getInputStream(), "UTF-16")); 

while((line = reader.readLine()) != null) { 
    // call callable here for each line 
    // PersonParser that implements Callable<Person> 
} 
reader.close(); 

Comment puis-je structurer pour obtenir dans mon futur objet. Tout conseil est le bienvenu.

Merci!

Answer 1

Utilisez la méthode Futures.sequence pour créer un Future<Iterable<Person>> d'un Iterable<Future<Person>>:

List<Future<Person>> personFutures = new ArrayList<Future<Person>>(); 
BufferedReader reader = 
    new BufferedReader(new InputStreamReader(getInputStream(), "UTF-16")); 

while((line = reader.readLine()) != null) { 
    PersonParser parser = new PersonParser(line); 
    personFutures.add(Futures.future(parser, system.dispatcher())); 
} 
reader.close(); 

Future<Iterable<Person>> personsFuture = 
    Futures.sequence(personFutures, system.dispatcher());