proste filter i map

PC22-ZaawansowaneElementyJavy/src/main/java/emps/strumieniowo/FilterMap.java

+package emps.strumieniowo;
+
+import java.util.List;
+
+public class FilterMap {
+	// Operacje na strumieniach zwykle łączy się w tzw. "pipeline", który:
+	// - zaczyna się od operacji tworzącej strumień
+	// - dalej posiada 0 lub więcej operacji pośrednich
+	// - na końcu ma operację terminującą.
+	
+	// W tym przykładzie przeplatamy najbardziej standardowe operacje na strumieniach:
+	// filter - sprawdza czy element strumienia spełnia warunek i tylko jeśli tak, to przepuszcza do następnego etapu
+	// map - na podstawie elementu wejściowego zwraca jakiś wynik, który jest przekazywany do nast. etapu
+	
+	public static void main(String[] args) {
+		List<Employee> emps = ObslugaCSV.wczytaj("emps.csv");
+		
+		emps.stream()
+			.filter(emp -> emp.getSalary() >= 10000)
+			.filter(emp -> "Seattle".equals(emp.getCity()))
+			.map(emp -> emp.getFirstName() + " " + emp.getLastName())
+			.filter(s -> s.contains("a"))
+			.map(s -> s.toUpperCase())
+			.forEach(s -> System.out.println(s));
+	}
+
+}

PC22-ZaawansowaneElementyJavy/src/main/java/emps/strumieniowo/FilterMap_v2.java

+package emps.strumieniowo;
+
+import java.util.List;
+
+public class FilterMap_v2 {
+	// Operacje na strumieniach zwykle łączy się w tzw. "pipeline", który:
+	// - zaczyna się od operacji tworzącej strumień
+	// - dalej posiada 0 lub więcej operacji pośrednich
+	// - na końcu ma operację terminującą.
+	
+	// W tym przykładzie przeplatamy najbardziej standardowe operacje na strumieniach:
+	// filter - sprawdza czy element strumienia spełnia warunek i tylko jeśli tak, to przepuszcza do następnego etapu
+	// map - na podstawie elementu wejściowego zwraca jakiś wynik, który jest przekazywany do nast. etapu
+	
+	// W tej wersji tam, gdzie można, zamiast wyrażenia lambda -> zastosujemy method reference ::
+	public static void main(String[] args) {
+		List<Employee> emps = ObslugaCSV.wczytaj("emps.csv");
+		
+		emps.stream()
+			.filter(emp -> emp.getSalary() >= 10000)
+			.filter(emp -> "Seattle".equals(emp.getCity()))
+			.map(emp -> emp.getFirstName() + " " + emp.getLastName())
+			.filter(s -> s.contains("a"))
+			.map(String::toUpperCase)
+			.forEach(System.out::println);
+	}
+
+}

PC22-ZaawansowaneElementyJavy/src/main/java/emps/strumieniowo/P1_WypiszZeStrumienia.java

+package emps.strumieniowo;
+
+import java.util.List;
+
+// W tym przykładzie z listy pobierany jest obiekt "stream",
+// a dopiero na nim wywołujemy forEach.
+// Wydaje się to bez sensu, bo forEach działa dla listy (zob. wersję 0),
+// ale stream() daje dostęp do wielu dodatkowych operacji, co zobaczymy w nast. przykładach.
+public class P1_WypiszZeStrumienia {
+
+	public static void main(String[] args) {
+		List<Employee> emps = ObslugaCSV.wczytaj("emps.csv");
+		
+		emps.stream().forEach(emp ->
+			System.out.printf("Pracownik %s %s (%s) zarabia %d\n",
+				emp.getFirstName(), emp.getLastName(), emp.getJobTitle(), emp.getSalary()));
+	}
+
+}

PC22-ZaawansowaneElementyJavy/src/main/java/emps/strumieniowo/P2_WypiszBogatych.java

+package emps.strumieniowo;
+
+import java.util.List;
+
+public class P2_WypiszBogatych {
+
+	public static void main(String[] args) {
+		List<Employee> emps = ObslugaCSV.wczytaj("emps.csv");
+		
+		emps.stream()
+			.filter(emp -> emp.getSalary() >= 10000)
+			.forEach(emp ->	System.out.printf("Pracownik %s %s (%s) zarabia %d\n",
+							emp.getFirstName(), emp.getLastName(), emp.getJobTitle(), emp.getSalary()));
+	}
+
+}