Kako se vrši identifikacija međustadija obrade podataka u tokovima?

U Java Stream API, međuzavisne operacije (intermediate operations) se identifikuju po njihovom lenjivom karakteru: one vraćaju novi tok (Stream) i ne pokreću obradu podataka odmah. To ih razlikuje od terminalnih operacija, koje pokreću računanja.

Međuzavisne operacije se mogu prepoznati po tome što vraćaju Stream i omogućavaju lančano pozivanje, na primer:

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

Ovde su filter i map međuzavisne operacije, one ne izvršavaju obradu odmah, već formiraju cevovod (pipeline). Obrada će početi tek kada se pozove terminalna operacija, poput collect ili forEach.

Takođe, identifikacija međuzavisnih faza se vrši na osnovu njihovog tipa povratne vrednosti (Stream) i njihovog lenjivog ponašanja.