How to exit Java stream processing after a required number of results?

Question

I have following code which uses Stream API to find names of first 3 elements in a collection which have calories more than 300:

List<Dish> dishes = ....
List<String> unhealthyDishes = dishes.stream()
                                     .filter(dish -> dish.getCalories() > 300)
                                     .map(dish -> dish.getName())
                                     .limit(3)
                                     .collect(Collectors.toList());

In traditional iterator based imperative approach, I can keep count of the results and hence exit the iteration loop once I have got required number of elements. But above code seems to go through the entire length of the collection. How can I stop it doing so and stop once I have got 3 elements I need?

java 8 java stream

tdranv · Accepted Answer

How do you know it checks the other elements as well? I just set up this small test:
String[] words = {"a", "a", "a", "aa"};
        
List<Integer> shortWords = Arrays.stream(words)
     .filter(word -> {
             System.out.println("checking " + word);
             return word.length() == 1;
             })
     .map(String::length)
     .limit(3)
     .collect(Collectors.toList());
        
System.out.println(shortWords);

And the output was:
checking a
checking a
checking a
[1, 1, 1]

How to exit Java stream processing after a required number of results?

One Answer

Add your own answers!

Related Questions

Remove item from state

How to create two different Menu in one page for different type of user in HTML using PHP and CSS

A simple IF statement in Python 3.X Pandas not working

How to concatenate 3 lists even if there are a list null?

Angular 8: Select first element of ng-content

docker-compose volume empty

Trying to remove suffix from string with no success

Extract value of column from a line (variable)

Sequelize – N:M Association Count Number of Included Model with Condition

Include device location and multiple map markers in camera bounds

How to generalize a code for exporting DataGridView to Excel file?

Merge Two Files in Weka based on date

Gorilla Mux Router GET URL with multiple query param only matches if called by all query params

Set Session ID Cookie in Nuxt Auth

Exo player add raise/send analytics event total time spent

Why are arrow functions as static members values not lexically scoped?

Undefined error after webservice .asmx returns successful json data

Debugging an Expo project with Attach to Debugger option throws t.RawDebugSession.handleErrorResponse error after a while or saving changes

What is causing the error “the best overloaded method match for ‘UnityEngine.WaitUntil.WaitUntil(system.func) has some invalid arguments”?

Warnings in gcc compiler

Ask a Question