У меня проблема с потоками Java 8, когда данные обрабатываются внезапно, а не тогда, когда они запрашиваются. У меня довольно сложный поток, который должен быть распараллелен, потому что я используюconcat объединить два потока.

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

Итак, вопрос в том, почему происходит этот массовый сбор и как я могу его избежать.

Мой ввод - Spliterator неизвестного размера, и я использую forEach в качестве операции терминала.