Как планировать поток потоков в Java?
Я хочу преобразовать поток потоков объектов в один поток объектов. Я знаю, что мне нужно использовать метод flatMap, но я не могу его заархивировать.
Stream<Stream<Object>> objectStreams = ...
Stream<Object> flatMappedStream = objectStreams.flatMap( ... );
Может ли кто-нибудь помочь мне?
Ответы
Ответ 1
В принципе, вы хотите объединить все вложенные потоки в один плоский поток, не затрагивая самих членов. Вы будете использовать
objectStreams.flatMap(Function.identity());
потому что вы должны предоставить некоторую функцию отображения для каждого члена потока, и в этом случае это функция тождества.
