В рамках стрима я не смог красиво распараллелить обработку map в Flow (смотрите видео), но за выходные я покодил и нашел какое решение можно применить
Не скажу что оно лучше, но мне нравится тем что это каноничный подход обработки внутри flow, без внешних входных данных внутри операторов.