Cum se realizează identificarea etapelor intermediare în procesarea datelor în operațiile de streaming?

În API-ul Stream din Java, operațiile intermediare sunt identificate prin caracterul lor leneș: acestea returnează un nou flux și nu inițiază procesarea datelor imediat. Acest lucru le diferențiază de operațiile terminale, care pornesc calculele.

Operațiile intermediare pot fi recunoscute după faptul că returnează un Stream și permit construirea unui lanț de apeluri, de exemplu:

Stream<String> stream = list.stream()
    .filter(s -> s.startsWith("A"))  // operație intermediară
    .map(String::toUpperCase);         // operație intermediară

Aici, filter și map sunt operații intermediare, nu execută procesarea imediat, ci formează un pipeline. Procesarea va începe doar când se apelează o operație terminală, cum ar fi collect sau forEach.

Prin urmare, identificarea etapelor intermediare se face pe baza tipului lor de returnare (Stream) și a comportamentului lor leneș.