Как сделать поток (java.util.stream) из несформированного источника?
Всем привет! В java новичок, не обессудьте.
Прочел я про java.util.stream. Подход понравился, начал повсеместно использовать, но только на основе готовых коллекций.
Вот встала задача: Есть некий API, мне нужно стянуть с него 200 000 записей и обработать в java.util.stream стиле. К апи я обращаюсь в 50 потоков, каждый из которых делает 4 000 запросов. После получения одной записи ее нужно обработать (ждать пока скачаются все 200 000 записей не оптимально и затратно).
Получается что нужно сделать какой-то асинхронный итератор/коллекцию из которого и создавать поток? Или как-то по другому? Как лучше сделать подобное в потоковом стиле?