Руководство Akka Futures

Question

Я пытаюсь использовать Akka Futures для чтения нескольких файлов и передачи каждой строки вызываемому. Мои вызывающие элементы - это синтаксические анализаторы для определенного файла. Таким образом, people.txt может заполнять объекты типа Person. Каждая строка может содержать более 50 полей, каждая из которых нуждается в проверке и операции для заполнения объекта.

Так что я хотел бы получить что-то вроде Future <Iterable<Person>> назад, но не знаю, как я понимаю, что от

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(); 

Как можно структурировать это, чтобы получить это в моем будущем объекте. Любые советы приветствуются.

Спасибо!

Answer 1

Используйте метод Futures.sequence создать Future<Iterable<Person>> из 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());