List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8);
List<Integer> twoEvenSquares = numbers.stream().filter(n -> {
System.out.println("filtering " + n);
return n % 2 == 0;
}).map(n -> {
System.out.println("mapping " + n);
return n * n;
}).limit(2).collect(Collectors.toList());
for(Integer i : twoEvenSquares)
{
System.out.println(i);
}
when executed the logic below output came
filtering 1
filtering 2
mapping 2
filtering 3
filtering 4
mapping 4
4
16
if the stream follows the short circuit concept (where we use limit stream operation), then output must be like below:
filtering 1
filtering 2
filtering 3
filtering 4
mapping 2
mapping 4
4
16
because after filtering 2, we have to still find one more element to stratify limit(2), operation, so why the output is not coming like I explained?
Streams are pull-based. Only a terminal operations (like the collect
) will cause items to be consumed.
Conceptually this means that collect
will ask an item from the limit
, limit
from the map
and map
from the filter
, and filter
from the stream.
Schematically the code in your question leads to
collect
limit (0)
map
filter
stream (returns 1)
/filter (false)
filter
stream (returns 2)
/filter (true)
/map (returns 4)
/limit (1)
limit (1)
map
filter
stream (returns 3)
/filter (false)
filter
stream (returns 4)
/filter (true)
/map (returns 16)
/limit (2)
limit (2)
/limit (no more items; limit reached)
/collect
And this conforms to your first printout.
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With