Kaip vykdoma tarpinio duomenų apdorojimo etapų identifikacija srautinėse operacijose?

Java Stream API, tarpinės operacijos (intermediate operations) yra identifikuojamos pagal jų tingų pobūdį: jos grąžina naują srautą (Stream) ir nepradeda duomenų apdorojimo iš karto. Tai jas skiria nuo terminalinių operacijų, kurios pradeda skaičiavimus.

Tarpines operacijas galima atpažinti pagal tai, kad jos grąžina Stream ir leidžia kurti eilės iškvietimų grandines, pavyzdžiui:

Stream<String> stream = list.stream()
    .filter(s -> s.startsWith("A"))  // tarpinė operacija
    .map(String::toUpperCase);         // tarpinė operacija

Čia filter ir map yra tarpinės operacijos, jos nevykdo apdorojimo iš karto, o tik sudaro vamzdyną (pipeline). Apdorojimas prasidės tik iškvietus terminalinę operaciją, pavyzdžiui, collect arba forEach.

Taigi, tarpiniai etapų identifikavimas vyksta pagal jų grąžinamo tipo (Stream) ir jų tingų elgesio pagrindu.