-
Notifications
You must be signed in to change notification settings - Fork 3
/
StreamDemo.java
117 lines (91 loc) · 3.15 KB
/
StreamDemo.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
package main.java;
import java.util.Arrays;
import java.util.Comparator;
import java.util.List;
import java.util.function.Consumer;
import java.util.function.Function;
import java.util.function.Predicate;
public class StreamDemo {
public static void main(String[] args) {
List<Employee> employees=Arrays.asList(new Employee(101,"hemendra", Arrays.asList(8789389494l,7927629769l)),
new Employee(102,"aditi",Arrays.asList(692769791l,1789756917697l)));
// counting the total number of items in the list
System.out.println(employees.stream().count());
// Looking for any of the match based on the object which we pass
System.out.println(employees.stream().anyMatch(new Predicate<Employee>() {
@Override
public boolean test(Employee employee) {
return employee.getName().contains("ndra");
}
}));
// limiting the list result to 1
employees.stream().limit(1).forEach(new Consumer<Employee>() {
@Override
public void accept(Employee employee) {
System.out.println(employee);
}
});
// Sorting the list based on name and limiting the result to 1
employees.stream().sorted(new Comparator<Employee>() {
@Override
public int compare(Employee o1, Employee o2) {
return o1.getName().compareTo(o2.getName());
}
}).limit(1).forEach(new Consumer<Employee>() {
@Override
public void accept(Employee employee) {
System.out.println(employee);
}
});
// Converting the name of the employee to upper case and returning the string
employees.stream().map(new Function<Employee, Object>() {
@Override
public Object apply(Employee employee) {
return employee.getName().toUpperCase();
}
}).forEach(new Consumer<Object>() {
@Override
public void accept(Object o) {
System.out.println(o);
}
});
}
}
class Employee{
private int id;
private String name;
private List<Long> contactNumber;
public Employee() {
}
public Employee(int id, String name, List<Long> contactNumber) {
this.id = id;
this.name = name;
this.contactNumber = contactNumber;
}
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public List<Long> getContactNumber() {
return contactNumber;
}
public void setContactNumber(List<Long> contactNumber) {
this.contactNumber = contactNumber;
}
@Override
public String toString() {
return "Employee{" +
"id=" + id +
", name='" + name + '\'' +
", contactNumber=" + contactNumber +
'}';
}
}