Eu tenho um problema com os fluxos do Java 8, em que os dados são processados em grandes quantidades repentinas, e não quando solicitados. Eu tenho um fluxo de fluxo bastante complexo que precisa ser paralelizado porque eu usoconcat mesclar dois fluxos.

Meu problema decorre do fato de que os dados parecem ser analisados em grandes volumes a cada minuto - e às vezes até horas -. Eu esperaria que esse processamento acontecesse assim que oStream lê dados recebidos, para espalhar a carga de trabalho. O processamento em massa parece contra-intuitivo em quase todos os aspectos.

Portanto, a questão é por que essa coleta em massa ocorre e como posso evitá-la.

Minha entrada é um Spliterator de tamanho desconhecido e uso um forEach como operação do terminal.