Как преобразовать список Futures в поток без вызова Future.get? ⇐ JAVA

[Anonymous]

Предположим, у меня есть список объектов Future.

Код: Выделить всё

List futures. Я хочу преобразовать его в один поток

.

Очевидно, я могу сделать так:

Код: Выделить всё

List list=new ArrayList();
for(Future future:futures){
list.addAll(future.get());
}
return list.steam();

Но этот метод должен дождаться возврата всех фьючерсов, прежде чем он сможет вернуть Stream.

Я хочу, чтобы он работал как конвейер, верхний уровень извлекайте данные из потока и обрабатывайте их по мере необходимости, не нужно ждать завершения всех фьючерсов.

Подробнее здесь: https://stackoverflow.com/questions/657 ... future-get