Merge remote-tracking branch 'upstream/master'

2016-07-02 20:22:30 -05:00
parent 1203bb5d69 f78ba65664
commit be5bfeccd0
230 changed files with 11047 additions and 716 deletions
@@ -7,8 +7,11 @@

 # Eclipse
 .settings/
+*.project
+*.classpath
 .prefs
 *.prefs
+.metadata/

 # Intellij
 .idea/
@@ -23,3 +26,4 @@ log/
 target/

 spring-openid/src/main/resources/application.properties
+.recommenders/
@@ -1,7 +1,7 @@

 The "REST with Spring" Classes
 ==============================
-After 5 months of work, here's the Master Class: <br/>
+After 5 months of work, here's the Master Class of REST With Spring: <br/>
 **[>> THE REST WITH SPRING MASTER CLASS](http://www.baeldung.com/rest-with-spring-course?utm_source=github&utm_medium=social&utm_content=tutorials&utm_campaign=rws#master-class)**


@@ -19,3 +19,8 @@ Any IDE can be used to work with the projects, but if you're using Eclipse, cons

 - import the included **formatter** in Eclipse: 
 `https://github.com/eugenp/tutorials/tree/master/eclipse`
+
+
+CI - Jenkins
+================================
+This tutorials project is being built **[>> HERE](https://rest-security.ci.cloudbees.com/job/tutorials/)**
@@ -0,0 +1,38 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.baeldung</groupId>
+    <artifactId>assertj</artifactId>
+    <version>1.0.0-SNAPSHOT</version>
+
+    <dependencies>
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <version>4.12</version>
+        </dependency>
+        <dependency>
+            <groupId>org.assertj</groupId>
+            <artifactId>assertj-core</artifactId>
+            <version>3.4.1</version>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>3.3</version>
+                <configuration>
+                    <source>1.8</source>
+                    <target>1.8</target>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+</project>
@@ -0,0 +1,19 @@
+package com.baeldung.assertj.introduction.domain;
+
+public class Dog {
+    private String name;
+    private Float weight;
+
+    public Dog(String name, Float weight) {
+        this.name = name;
+        this.weight = weight;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public Float getWeight() {
+        return weight;
+    }
+}
@@ -0,0 +1,19 @@
+package com.baeldung.assertj.introduction.domain;
+
+public class Person {
+    private String name;
+    private Integer age;
+
+    public Person(String name, Integer age) {
+        this.name = name;
+        this.age = age;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public Integer getAge() {
+        return age;
+    }
+}
@@ -0,0 +1,143 @@
+package com.baeldung.assertj.introduction;
+
+import com.baeldung.assertj.introduction.domain.Dog;
+import com.baeldung.assertj.introduction.domain.Person;
+import org.assertj.core.util.Maps;
+import org.junit.Ignore;
+import org.junit.Test;
+
+import java.io.ByteArrayInputStream;
+import java.io.File;
+import java.io.InputStream;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
+import java.util.NoSuchElementException;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.assertj.core.api.Assertions.entry;
+import static org.assertj.core.api.Assertions.withPrecision;
+
+public class AssertJCoreTest {
+
+    @Test
+    public void whenComparingReferences_thenNotEqual() throws Exception {
+        Dog fido = new Dog("Fido", 5.15f);
+        Dog fidosClone = new Dog("Fido", 5.15f);
+
+        assertThat(fido).isNotEqualTo(fidosClone);
+    }
+
+    @Test
+    public void whenComparingFields_thenEqual() throws Exception {
+        Dog fido = new Dog("Fido", 5.15f);
+        Dog fidosClone = new Dog("Fido", 5.15f);
+
+        assertThat(fido).isEqualToComparingFieldByFieldRecursively(fidosClone);
+    }
+
+    @Test
+    public void whenCheckingForElement_thenContains() throws Exception {
+        List<String> list = Arrays.asList("1", "2", "3");
+
+        assertThat(list)
+                .contains("1");
+    }
+
+    @Test
+    public void whenCheckingForElement_thenMultipleAssertions() throws Exception {
+        List<String> list = Arrays.asList("1", "2", "3");
+
+        assertThat(list).isNotEmpty();
+        assertThat(list).startsWith("1");
+        assertThat(list).doesNotContainNull();
+
+        assertThat(list)
+                .isNotEmpty()
+                .contains("1")
+                .startsWith("1")
+                .doesNotContainNull()
+                .containsSequence("2", "3");
+    }
+
+    @Test
+    public void whenCheckingRunnable_thenIsInterface() throws Exception {
+        assertThat(Runnable.class).isInterface();
+    }
+
+    @Test
+    public void whenCheckingCharacter_thenIsUnicode() throws Exception {
+        char someCharacter = 'c';
+
+        assertThat(someCharacter)
+                .isNotEqualTo('a')
+                .inUnicode()
+                .isGreaterThanOrEqualTo('b')
+                .isLowerCase();
+    }
+
+    @Test
+    public void whenAssigningNSEExToException_thenIsAssignable() throws Exception {
+        assertThat(Exception.class).isAssignableFrom(NoSuchElementException.class);
+    }
+
+    @Test
+    public void whenComparingWithOffset_thenEquals() throws Exception {
+        assertThat(5.1).isEqualTo(5, withPrecision(1d));
+    }
+
+    @Test
+    public void whenCheckingString_then() throws Exception {
+        assertThat("".isEmpty()).isTrue();
+    }
+
+    @Test
+    public void whenCheckingFile_then() throws Exception {
+        final File someFile = File.createTempFile("aaa", "bbb");
+        someFile.deleteOnExit();
+
+        assertThat(someFile)
+                .exists()
+                .isFile()
+                .canRead()
+                .canWrite();
+    }
+
+    @Test
+    public void whenCheckingIS_then() throws Exception {
+        InputStream given = new ByteArrayInputStream("foo".getBytes());
+        InputStream expected = new ByteArrayInputStream("foo".getBytes());
+
+        assertThat(given).hasSameContentAs(expected);
+    }
+
+    @Test
+    public void whenGivenMap_then() throws Exception {
+        Map<Integer, String> map = Maps.newHashMap(2, "a");
+
+        assertThat(map)
+                .isNotEmpty()
+                .containsKey(2)
+                .doesNotContainKeys(10)
+                .contains(entry(2, "a"));
+    }
+
+    @Test
+    public void whenGivenException_then() throws Exception {
+        Exception ex = new Exception("abc");
+
+        assertThat(ex)
+                .hasNoCause()
+                .hasMessageEndingWith("c");
+    }
+
+    @Ignore // IN ORDER TO TEST, REMOVE THIS LINE
+    @Test
+    public void whenRunningAssertion_thenDescribed() throws Exception {
+        Person person = new Person("Alex", 34);
+
+        assertThat(person.getAge())
+                .as("%s's age should be equal to 100")
+                .isEqualTo(100);
+    }
+}
@@ -41,6 +41,12 @@
            <version>3.3.2</version>
        </dependency>

+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-api</artifactId>
+            <version>${org.slf4j.version}</version>
+        </dependency>
+
        <!-- test scoped -->

        <dependency>
@@ -57,6 +63,12 @@
            <scope>test</scope>
        </dependency>

+        <dependency>
+            <groupId>org.assertj</groupId>
+            <artifactId>assertj-core</artifactId>
+            <version>3.4.1</version>
+        </dependency>
+
        <dependency>
            <groupId>org.mockito</groupId>
            <artifactId>mockito-core</artifactId>
@@ -0,0 +1,16 @@
+package com.baeldung.datetime;
+
+import java.time.Duration;
+import java.time.LocalTime;
+import java.time.Period;
+
+public class UseDuration {
+    
+    public LocalTime modifyDates(LocalTime localTime,Duration duration){
+        return localTime.plus(duration);
+    }
+    
+    public Duration getDifferenceBetweenDates(LocalTime localTime1,LocalTime localTime2){
+        return Duration.between(localTime1, localTime2);
+    }
+}
@@ -0,0 +1,46 @@
+package com.baeldung.datetime;
+
+import java.time.DayOfWeek;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.temporal.ChronoUnit;
+import java.time.temporal.TemporalAdjusters;
+
+public class UseLocalDate {
+    
+    public LocalDate getLocalDateUsingFactoryOfMethod(int year, int month, int dayOfMonth){        
+        return LocalDate.of(year, month, dayOfMonth);
+    }
+    
+    public LocalDate getLocalDateUsingParseMethod(String representation){        
+        return LocalDate.parse(representation);
+    }
+    
+    public LocalDate getLocalDateFromClock(){        
+        LocalDate localDate = LocalDate.now();
+        return localDate;
+    }
+    
+    public LocalDate getNextDay(LocalDate localDate){       
+        return localDate.plusDays(1);
+    }
+    
+    public LocalDate getPreviousDay(LocalDate localDate){        
+        return localDate.minus(1, ChronoUnit.DAYS);
+    }
+    
+    public DayOfWeek getDayOfWeek(LocalDate localDate){        
+        DayOfWeek day = localDate.getDayOfWeek();
+        return day;
+    }
+    
+    public LocalDate getFirstDayOfMonth(){        
+        LocalDate firstDayOfMonth = LocalDate.now().with(TemporalAdjusters.firstDayOfMonth());
+        return firstDayOfMonth;
+    }
+    
+    public LocalDateTime getStartOfDay(LocalDate localDate){        
+        LocalDateTime startofDay = localDate.atStartOfDay();
+        return startofDay;
+    }
+}
@@ -0,0 +1,11 @@
+package com.baeldung.datetime;
+
+import java.time.LocalDateTime;
+
+public class UseLocalDateTime {
+    
+    public LocalDateTime getLocalDateTimeUsingParseMethod(String representation){        
+        return LocalDateTime.parse(representation);
+    }
+
+}
@@ -0,0 +1,35 @@
+package com.baeldung.datetime;
+
+import java.time.LocalTime;
+import java.time.temporal.ChronoUnit;
+
+public class UseLocalTime {
+    
+    public LocalTime getLocalTimeUsingFactoryOfMethod(int hour, int min, int seconds){        
+        LocalTime localTime = LocalTime.of(hour, min, seconds);
+        return localTime;
+    }
+    
+    public LocalTime getLocalTimeUsingParseMethod(String timeRepresentation){        
+        LocalTime localTime = LocalTime.parse(timeRepresentation);
+        return localTime;
+    }
+    
+    public LocalTime getLocalTimeFromClock(){        
+        LocalTime localTime = LocalTime.now();
+        return localTime;
+    }
+    
+    public LocalTime addAnHour(LocalTime localTime){
+        LocalTime newTime = localTime.plus(1,ChronoUnit.HOURS);
+        return newTime;
+    }
+    
+    public int getHourFromLocalTime(LocalTime localTime){        
+        return localTime.getHour();
+    }
+    
+    public LocalTime getLocalTimeWithMinuteSetToValue(LocalTime localTime, int minute){        
+        return localTime.withMinute(minute);
+    }
+}
@@ -0,0 +1,15 @@
+package com.baeldung.datetime;
+
+import java.time.LocalDate;
+import java.time.Period;
+
+public class UsePeriod {
+    
+    public LocalDate modifyDates(LocalDate localDate,Period period){
+        return localDate.plus(period);
+    }
+    
+    public Period getDifferenceBetweenDates(LocalDate localDate1,LocalDate localDate2){
+        return Period.between(localDate1, localDate2);
+    }
+}
@@ -0,0 +1,19 @@
+package com.baeldung.datetime;
+
+import java.time.LocalDateTime;
+import java.time.ZoneId;
+import java.util.Calendar;
+import java.util.Date;
+
+public class UseToInstant {
+    
+    public LocalDateTime convertDateToLocalDate(Date date){
+        LocalDateTime localDateTime = LocalDateTime.ofInstant(date.toInstant(), ZoneId.systemDefault());
+        return localDateTime;
+    }
+    
+    public LocalDateTime convertDateToLocalDate(Calendar calendar){
+        LocalDateTime localDateTime = LocalDateTime.ofInstant(calendar.toInstant(), ZoneId.systemDefault());
+        return localDateTime;
+    }
+}
@@ -0,0 +1,13 @@
+package com.baeldung.datetime;
+
+import java.time.LocalDateTime;
+import java.time.ZoneId;
+import java.time.ZonedDateTime;
+
+public class UseZonedDateTime {
+    
+    public ZonedDateTime getZonedDateTime(LocalDateTime localDateTime,ZoneId zoneId){        
+        ZonedDateTime zonedDateTime = ZonedDateTime.of(localDateTime, zoneId);
+        return zonedDateTime;
+    }
+}
@@ -0,0 +1,51 @@
+package com.baeldung.streamApi;
+
+import java.util.List;
+import java.util.Optional;
+import java.util.stream.IntStream;
+import java.util.stream.Stream;
+
+/**
+ * Created by Alex Vengr
+ */
+public class Product {
+
+    private int price;
+
+    private String name;
+
+    private boolean utilize;
+
+    public Product(int price, String name) {
+        this(price);
+        this.name = name;
+    }
+
+    public Product(int price) {
+        this.price = price;
+    }
+
+    public Product() {
+    }
+
+    public int getPrice() {
+        return price;
+    }
+
+    public void setPrice(int price) {
+        this.price = price;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+
+    public static Stream<String> streamOf(List<String> list) {
+        return (list == null || list.isEmpty()) ? Stream.empty() : list.stream();
+    }
+}
@@ -0,0 +1,19 @@
+package com.baeldung.dateapi;
+
+import java.time.Instant;
+import java.time.ZoneId;
+import java.time.ZonedDateTime;
+import java.util.Date;
+import java.util.GregorianCalendar;
+import java.util.TimeZone;
+
+public class ConversionExample {
+    public static void main(String[] args) {
+        Instant instantFromCalendar = GregorianCalendar.getInstance().toInstant();
+        ZonedDateTime zonedDateTimeFromCalendar = new GregorianCalendar().toZonedDateTime();
+        Date dateFromInstant = Date.from(Instant.now());
+        GregorianCalendar calendarFromZonedDateTime = GregorianCalendar.from(ZonedDateTime.now());
+        Instant instantFromDate = new Date().toInstant();
+        ZoneId zoneIdFromTimeZone = TimeZone.getTimeZone("PST").toZoneId();
+    }
+}
@@ -0,0 +1,89 @@
+package com.baeldung.dateapi;
+
+import org.junit.Test;
+
+import java.text.ParseException;
+import java.time.Duration;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.LocalTime;
+import java.time.Month;
+import java.time.YearMonth;
+import java.time.format.DateTimeFormatter;
+import java.time.temporal.ChronoUnit;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+public class JavaUtilTimeTest {
+
+    @Test
+    public void currentTime() {
+        final LocalDate now = LocalDate.now();
+
+        System.out.println(now);
+        // there is not much to test here
+    }
+
+    @Test
+    public void specificTime() {
+        LocalDate birthDay = LocalDate.of(1990, Month.DECEMBER, 15);
+
+        System.out.println(birthDay);
+        // there is not much to test here
+    }
+
+    @Test
+    public void extractMonth() {
+        Month month = LocalDate.of(1990, Month.DECEMBER, 15).getMonth();
+
+        assertThat(month).isEqualTo(Month.DECEMBER);
+    }
+
+    @Test
+    public void subtractTime() {
+        LocalDateTime fiveHoursBefore = LocalDateTime.of(1990, Month.DECEMBER, 15, 15, 0).minusHours(5);
+
+        assertThat(fiveHoursBefore.getHour()).isEqualTo(10);
+    }
+
+    @Test
+    public void alterField() {
+        LocalDateTime inJune = LocalDateTime.of(1990, Month.DECEMBER, 15, 15, 0).with(Month.JUNE);
+
+        assertThat(inJune.getMonth()).isEqualTo(Month.JUNE);
+    }
+
+    @Test
+    public void truncate() {
+        LocalTime truncated = LocalTime.of(15, 12, 34).truncatedTo(ChronoUnit.HOURS);
+
+        assertThat(truncated).isEqualTo(LocalTime.of(15, 0, 0));
+    }
+
+    @Test
+    public void getTimeSpan() {
+        LocalDateTime now = LocalDateTime.now();
+        LocalDateTime hourLater = now.plusHours(1);
+        Duration span = Duration.between(now, hourLater);
+
+        assertThat(span).isEqualTo(Duration.ofHours(1));
+    }
+
+    @Test
+    public void formatAndParse() throws ParseException {
+        LocalDate someDate = LocalDate.of(2016, 12, 7);
+        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
+        String formattedDate = someDate.format(formatter);
+        LocalDate parsedDate = LocalDate.parse(formattedDate, formatter);
+
+        assertThat(formattedDate).isEqualTo("2016-12-07");
+        assertThat(parsedDate).isEqualTo(someDate);
+    }
+
+    @Test
+    public void daysInMonth() {
+        int daysInMonth = YearMonth.of(1990, 2).lengthOfMonth();
+
+        assertThat(daysInMonth).isEqualTo(28);
+    }
+}
@@ -0,0 +1,55 @@
+package com.baeldung.datetime;
+
+import java.time.DayOfWeek;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.Month;
+
+import org.junit.Assert;
+import org.junit.Test;
+
+public class UseLocalDateTest {
+    
+    UseLocalDate useLocalDate = new UseLocalDate();
+    
+    @Test
+    public void givenValues_whenUsingFactoryOf_thenLocalDate(){
+        Assert.assertEquals("2016-05-10",useLocalDate.getLocalDateUsingFactoryOfMethod(2016,5,10).toString());
+    }
+    
+    @Test
+    public void givenString_whenUsingParse_thenLocalDate(){
+        Assert.assertEquals("2016-05-10",useLocalDate.getLocalDateUsingParseMethod("2016-05-10").toString());
+    }
+    
+    @Test
+    public void whenUsingClock_thenLocalDate(){
+        Assert.assertEquals(LocalDate.now(),useLocalDate.getLocalDateFromClock());
+    }
+    
+    @Test
+    public void givenDate_whenUsingPlus_thenNextDay(){
+        Assert.assertEquals(LocalDate.now().plusDays(1),useLocalDate.getNextDay(LocalDate.now()));
+    }
+    
+    @Test
+    public void givenDate_whenUsingMinus_thenPreviousDay(){
+        Assert.assertEquals(LocalDate.now().minusDays(1),useLocalDate.getPreviousDay(LocalDate.now()));
+    }
+    
+    @Test
+    public void givenToday_whenUsingGetDayOfWeek_thenDayOfWeek(){
+        Assert.assertEquals(DayOfWeek.SUNDAY,useLocalDate.getDayOfWeek(LocalDate.parse("2016-05-22")));
+    }
+    
+    @Test
+    public void givenToday_whenUsingWithTemporalAdjuster_thenFirstDayOfMonth(){
+        Assert.assertEquals(1,useLocalDate.getFirstDayOfMonth().getDayOfMonth());
+    }
+    
+    @Test
+    public void givenLocalDate_whenUsingAtStartOfDay_thenReturnMidnight(){
+        Assert.assertEquals(LocalDateTime.parse("2016-05-22T00:00:00"),useLocalDate.getStartOfDay(LocalDate.parse("2016-05-22")));
+    }
+
+}
@@ -0,0 +1,19 @@
+package com.baeldung.datetime;
+
+import java.time.LocalDate;
+import java.time.LocalTime;
+import java.time.Month;
+
+import org.junit.Assert;
+import org.junit.Test;
+
+public class UseLocalDateTimeTest {
+    
+    UseLocalDateTime useLocalDateTime = new UseLocalDateTime();
+    
+    @Test
+    public void givenString_whenUsingParse_thenLocalDateTime(){
+        Assert.assertEquals(LocalDate.of(2016, Month.MAY, 10),useLocalDateTime.getLocalDateTimeUsingParseMethod("2016-05-10T06:30").toLocalDate());
+        Assert.assertEquals(LocalTime.of(6,30),useLocalDateTime.getLocalDateTimeUsingParseMethod("2016-05-10T06:30").toLocalTime());
+    }
+}
@@ -0,0 +1,36 @@
+package com.baeldung.datetime;
+
+import java.time.LocalTime;
+
+import org.junit.Assert;
+import org.junit.Test;
+
+public class UseLocalTimeTest {
+    
+    UseLocalTime useLocalTime = new UseLocalTime();
+    
+    @Test
+    public void givenValues_whenUsingFactoryOf_thenLocalTime(){
+        Assert.assertEquals("07:07:07",useLocalTime.getLocalTimeUsingFactoryOfMethod(7,7,7).toString());
+    }
+    
+    @Test
+    public void givenString_whenUsingParse_thenLocalTime(){
+        Assert.assertEquals("06:30",useLocalTime.getLocalTimeUsingParseMethod("06:30").toString());
+    }
+    
+    @Test
+    public void givenTime_whenAddHour_thenLocalTime(){
+        Assert.assertEquals("07:30",useLocalTime.addAnHour(LocalTime.of(6,30)).toString());
+    }
+    
+    @Test
+    public void getHourFromLocalTime(){
+        Assert.assertEquals(1, useLocalTime.getHourFromLocalTime(LocalTime.of(1,1)));
+    }
+    
+    @Test
+    public void getLocalTimeWithMinuteSetToValue(){
+        Assert.assertEquals(LocalTime.of(10, 20), useLocalTime.getLocalTimeWithMinuteSetToValue(LocalTime.of(10,10), 20));
+    }
+}
@@ -0,0 +1,29 @@
+package com.baeldung.datetime;
+
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.Period;
+import java.time.ZoneId;
+import java.time.ZonedDateTime;
+
+import org.junit.Assert;
+import org.junit.Test;
+
+public class UsePeriodTest {
+    UsePeriod usingPeriod=new UsePeriod();
+    
+    @Test
+    public void givenPeriodAndLocalDate_thenCalculateModifiedDate(){
+        Period period = Period.ofDays(1);
+        LocalDate localDate = LocalDate.parse("2007-05-10");
+        Assert.assertEquals(localDate.plusDays(1),usingPeriod.modifyDates(localDate, period));
+    }
+    
+    @Test
+    public void givenDates_thenGetPeriod(){
+        LocalDate localDate1 = LocalDate.parse("2007-05-10");
+        LocalDate localDate2 = LocalDate.parse("2007-05-15");
+        
+        Assert.assertEquals(Period.ofDays(5), usingPeriod.getDifferenceBetweenDates(localDate1, localDate2));
+    }
+}
@@ -0,0 +1,20 @@
+package com.baeldung.datetime;
+
+import java.time.LocalDateTime;
+import java.time.ZoneId;
+import java.time.ZonedDateTime;
+
+import org.junit.Assert;
+import org.junit.Test;
+
+public class UseZonedDateTimeTest {
+    
+    UseZonedDateTime zonedDateTime=new UseZonedDateTime();
+    
+    @Test
+    public void givenZoneId_thenZonedDateTime(){
+        ZoneId zoneId=ZoneId.of("Europe/Paris");
+        ZonedDateTime zonedDatetime=zonedDateTime.getZonedDateTime(LocalDateTime.parse("2016-05-20T06:30"), zoneId);
+        Assert.assertEquals(zoneId,ZoneId.from(zonedDatetime));
+    }
+}
@@ -0,0 +1,263 @@
+package com.baeldung.java8;
+
+import com.baeldung.streamApi.Product;
+import org.junit.Before;
+import org.junit.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.BufferedWriter;
+import java.io.IOException;
+import java.nio.charset.Charset;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.util.*;
+import java.util.regex.Pattern;
+import java.util.stream.*;
+
+import static org.junit.Assert.*;
+
+public class Java8StreamApiTest {
+
+    private long counter;
+
+    private static Logger log = LoggerFactory.getLogger(Java8StreamApiTest.class);
+
+    private List<Product> productList;
+
+    @Before
+    public void init() {
+        productList = Arrays.asList(
+                new Product(23, "potatoes"), new Product(14, "orange"),
+                new Product(13, "lemon"), new Product(23, "bread"),
+                new Product(13, "sugar"));
+    }
+
+    @Test
+    public void checkPipeline_whenStreamOneElementShorter_thenCorrect() {
+
+        List<String> list = Arrays.asList("abc1", "abc2", "abc3");
+        long size = list.stream().skip(1)
+                .map(element -> element.substring(0, 3)).count();
+        assertEquals(list.size() - 1, size);
+    }
+
+    @Test
+    public void checkOrder_whenChangeQuantityOfMethodCalls_thenCorrect() {
+
+        List<String> list = Arrays.asList("abc1", "abc2", "abc3");
+
+        counter = 0;
+        long sizeFirst = list.stream()
+                .skip(2).map(element -> {
+                    wasCalled();
+                    return element.substring(0, 3);
+                }).count();
+        assertEquals(1, counter);
+
+        counter = 0;
+        long sizeSecond = list.stream().map(element -> {
+            wasCalled();
+            return element.substring(0, 3);
+        }).skip(2).count();
+        assertEquals(3, counter);
+    }
+
+    @Test
+    public void createEmptyStream_whenEmpty_thenCorrect() {
+
+        Stream<String> streamEmpty = Stream.empty();
+        assertEquals(0, streamEmpty.count());
+
+        List<String> names = Collections.emptyList();
+        Stream<String> streamOf = Product.streamOf(names);
+        assertTrue(streamOf.count() == 0);
+    }
+
+    @Test
+    public void createStream_whenCreated_thenCorrect() {
+
+        Collection<String> collection = Arrays.asList("a", "b", "c");
+        Stream<String> streamOfCollection = collection.stream();
+        assertEquals(3, streamOfCollection.count());
+
+        Stream<String> streamOfArray = Stream.of("a", "b", "c");
+        assertEquals(3, streamOfArray.count());
+
+        String[] arr = new String[]{"a", "b", "c"};
+        Stream<String> streamOfArrayPart = Arrays.stream(arr, 1, 3);
+        assertEquals(2, streamOfArrayPart.count());
+
+        IntStream intStream = IntStream.range(1, 3);
+        LongStream longStream = LongStream.rangeClosed(1, 3);
+        Random random = new Random();
+        DoubleStream doubleStream = random.doubles(3);
+        assertEquals(2, intStream.count());
+        assertEquals(3, longStream.count());
+        assertEquals(3, doubleStream.count());
+
+        IntStream streamOfChars = "abc".chars();
+        IntStream str = "".chars();
+        assertEquals(3, streamOfChars.count());
+
+        Stream<String> streamOfString = Pattern.compile(", ").splitAsStream("a, b, c");
+        assertEquals("a", streamOfString.findFirst().get());
+
+        Path path = getPath();
+        Stream<String> streamOfStrings = null;
+        try {
+            streamOfStrings = Files.lines(path, Charset.forName("UTF-8"));
+        } catch (IOException e) {
+            log.error("Error creating streams from paths {}", path, e.getMessage(), e);
+        }
+        assertEquals("a", streamOfStrings.findFirst().get());
+
+        Stream<String> streamBuilder = Stream.<String>builder().add("a").add("b").add("c").build();
+        assertEquals(3, streamBuilder.count());
+
+        Stream<String> streamGenerated = Stream.generate(() -> "element").limit(10);
+        assertEquals(10, streamGenerated.count());
+
+        Stream<Integer> streamIterated = Stream.iterate(40, n -> n + 2).limit(20);
+        assertTrue(40 <= streamIterated.findAny().get());
+    }
+
+    @Test
+    public void runStreamPipeline_whenOrderIsRight_thenCorrect() {
+
+        List<String> list = Arrays.asList("abc1", "abc2", "abc3");
+        Optional<String> stream = list.stream()
+                .filter(element -> {
+                    log.info("filter() was called");
+                    return element.contains("2");
+                }).map(element -> {
+                    log.info("map() was called");
+                    return element.toUpperCase();
+                }).findFirst();
+    }
+
+    @Test
+    public void reduce_whenExpected_thenCorrect() {
+
+        OptionalInt reduced = IntStream.range(1, 4).reduce((a, b) -> a + b);
+        assertEquals(6, reduced.getAsInt());
+
+        int reducedTwoParams = IntStream.range(1, 4).reduce(10, (a, b) -> a + b);
+        assertEquals(16, reducedTwoParams);
+
+        int reducedThreeParams = Stream.of(1, 2, 3)
+                .reduce(10, (a, b) -> a + b, (a, b) -> {
+                    log.info("combiner was called");
+                    return a + b;
+                });
+        assertEquals(16, reducedThreeParams);
+
+        int reducedThreeParamsParallel = Arrays.asList(1, 2, 3).parallelStream()
+                .reduce(10, (a, b) -> a + b, (a, b) -> {
+                    log.info("combiner was called");
+                    return a + b;
+                });
+        assertEquals(36, reducedThreeParamsParallel);
+    }
+
+    @Test
+    public void collecting_whenAsExpected_thenCorrect() {
+
+        List<String> collectorCollection = productList.stream()
+                .map(Product::getName).collect(Collectors.toList());
+
+        assertTrue(collectorCollection instanceof List);
+        assertEquals(5, collectorCollection.size());
+
+        String listToString = productList.stream().map(Product::getName)
+                .collect(Collectors.joining(", ", "[", "]"));
+
+        assertTrue(listToString.contains(",") && listToString.contains("[") && listToString.contains("]"));
+
+        double averagePrice = productList.stream().collect(Collectors.averagingInt(Product::getPrice));
+        assertTrue(17.2 == averagePrice);
+
+        int summingPrice = productList.stream().collect(Collectors.summingInt(Product::getPrice));
+        assertEquals(86, summingPrice);
+
+        IntSummaryStatistics statistics = productList.stream()
+                .collect(Collectors.summarizingInt(Product::getPrice));
+        assertEquals(23, statistics.getMax());
+
+        Map<Integer, List<Product>> collectorMapOfLists = productList.stream()
+                .collect(Collectors.groupingBy(Product::getPrice));
+        assertEquals(3, collectorMapOfLists.keySet().size());
+
+        Map<Boolean, List<Product>> mapPartioned = productList.stream()
+                .collect(Collectors.partitioningBy(element -> element.getPrice() > 15));
+        assertEquals(2, mapPartioned.keySet().size());
+
+    }
+
+    @Test(expected = UnsupportedOperationException.class)
+    public void collect_whenThrows_thenCorrect() {
+        Set<Product> unmodifiableSet = productList.stream()
+                .collect(Collectors.collectingAndThen(Collectors.toSet(),
+                        Collections::unmodifiableSet));
+        unmodifiableSet.add(new Product(4, "tea"));
+    }
+
+    @Test
+    public void customCollector_whenResultContainsAllElementsFrSource_thenCorrect() {
+        Collector<Product, ?, LinkedList<Product>> toLinkedList =
+                Collector.of(LinkedList::new, LinkedList::add,
+                        (first, second) -> {
+                            first.addAll(second);
+                            return first;
+                        });
+
+        LinkedList<Product> linkedListOfPersons = productList.stream().collect(toLinkedList);
+        assertTrue(linkedListOfPersons.containsAll(productList));
+    }
+
+    @Test
+    public void parallelStream_whenWorks_thenCorrect() {
+        Stream<Product> streamOfCollection = productList.parallelStream();
+        boolean isParallel = streamOfCollection.isParallel();
+        boolean haveBigPrice = streamOfCollection.map(product -> product.getPrice() * 12)
+                .anyMatch(price -> price > 200);
+        assertTrue(isParallel && haveBigPrice);
+    }
+
+    @Test
+    public void parallel_whenIsParallel_thenCorrect() {
+        IntStream intStreamParallel =
+                IntStream.range(1, 150).parallel().map(element -> element * 34);
+        boolean isParallel = intStreamParallel.isParallel();
+        assertTrue(isParallel);
+    }
+
+    @Test
+    public void parallel_whenIsSequential_thenCorrect() {
+        IntStream intStreamParallel =
+                IntStream.range(1, 150).parallel().map(element -> element * 34);
+        IntStream intStreamSequential = intStreamParallel.sequential();
+        boolean isParallel = intStreamParallel.isParallel();
+        assertFalse(isParallel);
+    }
+
+    private Path getPath() {
+        Path path = null;
+        try {
+            path = Files.createTempFile(null, ".txt");
+        } catch (IOException e) {
+            log.error(e.getMessage());
+        }
+
+        try (BufferedWriter writer = Files.newBufferedWriter(path)) {
+            writer.write("a\nb\nc");
+        } catch (IOException e) {
+            log.error(e.getMessage());
+        }
+        return path;
+    }
+
+    private void wasCalled() {
+        counter++;
+    }
+}
@@ -27,7 +27,7 @@
 			<attribute name="maven.pomderived" value="true"/>
 		</attributes>
 	</classpathentry>
-	<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.7">
+	<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.8">
 		<attributes>
 			<attribute name="owner.project.facets" value="java"/>
 		</attributes>
@@ -6,8 +6,13 @@ org.eclipse.jdt.core.compiler.annotation.nonnullbydefault=org.eclipse.jdt.annota
 org.eclipse.jdt.core.compiler.annotation.nullable=org.eclipse.jdt.annotation.Nullable
 org.eclipse.jdt.core.compiler.annotation.nullanalysis=disabled
 org.eclipse.jdt.core.compiler.codegen.inlineJsrBytecode=enabled
-org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.7
-org.eclipse.jdt.core.compiler.compliance=1.7
+org.eclipse.jdt.core.compiler.codegen.methodParameters=do not generate
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.8
+org.eclipse.jdt.core.compiler.codegen.unusedLocal=preserve
+org.eclipse.jdt.core.compiler.compliance=1.8
+org.eclipse.jdt.core.compiler.debug.lineNumber=generate
+org.eclipse.jdt.core.compiler.debug.localVariable=generate
+org.eclipse.jdt.core.compiler.debug.sourceFile=generate
 org.eclipse.jdt.core.compiler.problem.annotationSuperInterface=warning
 org.eclipse.jdt.core.compiler.problem.assertIdentifier=error
 org.eclipse.jdt.core.compiler.problem.autoboxing=ignore
@@ -92,4 +97,4 @@ org.eclipse.jdt.core.compiler.problem.unusedPrivateMember=warning
 org.eclipse.jdt.core.compiler.problem.unusedTypeParameter=ignore
 org.eclipse.jdt.core.compiler.problem.unusedWarningToken=warning
 org.eclipse.jdt.core.compiler.problem.varargsArgumentNeedCast=warning
-org.eclipse.jdt.core.compiler.source=1.7
+org.eclipse.jdt.core.compiler.source=1.8
@@ -1,4 +1,4 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <faceted-project>
-  <installed facet="java" version="1.7"/>
+  <installed facet="java" version="1.8"/>
 </faceted-project>
@@ -126,8 +126,8 @@
                <artifactId>maven-compiler-plugin</artifactId>
                <version>${maven-compiler-plugin.version}</version>
                <configuration>
-                    <source>1.7</source>
-                    <target>1.7</target>
+                    <source>1.8</source>
+                    <target>1.8</target>
                </configuration>
            </plugin>

@@ -3,37 +3,36 @@ package com.baeldung.enums;
 import com.fasterxml.jackson.annotation.JsonFormat;
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.fasterxml.jackson.databind.ObjectMapper;
-import org.apache.commons.collections15.CollectionUtils;
 import org.apache.commons.collections15.Predicate;

 import java.io.IOException;
-import java.util.ArrayList;
 import java.util.EnumMap;
 import java.util.EnumSet;
 import java.util.List;
+import java.util.stream.Collectors;

 public class Pizza {

-    private static EnumSet<PizzaStatusEnum> undeliveredPizzaStatuses =
-      EnumSet.of(PizzaStatusEnum.ORDERED, PizzaStatusEnum.READY);
+    private static EnumSet<PizzaStatus> undeliveredPizzaStatuses =
+            EnumSet.of(PizzaStatus.ORDERED, PizzaStatus.READY);

-    private PizzaStatusEnum status;
+    private PizzaStatus status;

    @JsonFormat(shape = JsonFormat.Shape.OBJECT)
-    public enum PizzaStatusEnum {
-        ORDERED (5){
+    public enum PizzaStatus {
+        ORDERED(5) {
            @Override
            public boolean isOrdered() {
                return true;
            }
        },
-        READY (2){
+        READY(2) {
            @Override
            public boolean isReady() {
                return true;
            }
        },
-        DELIVERED (0){
+        DELIVERED(0) {
            @Override
            public boolean isDelivered() {
                return true;
@@ -42,26 +41,33 @@ public class Pizza {

        private int timeToDelivery;

-        public boolean isOrdered() {return false;}
+        public boolean isOrdered() {
+            return false;
+        }

-        public boolean isReady() {return false;}
+        public boolean isReady() {
+            return false;
+        }
+
+        public boolean isDelivered() {
+            return false;
+        }

-        public boolean isDelivered(){return  false;}
        @JsonProperty("timeToDelivery")
        public int getTimeToDelivery() {
            return timeToDelivery;
        }

-        private PizzaStatusEnum (int timeToDelivery) {
+        PizzaStatus(int timeToDelivery) {
            this.timeToDelivery = timeToDelivery;
        }
    }

-    public PizzaStatusEnum getStatus() {
+    public PizzaStatus getStatus() {
        return status;
    }

-    public void setStatus(PizzaStatusEnum status) {
+    public void setStatus(PizzaStatus status) {
        this.status = status;
    }

@@ -73,32 +79,23 @@ public class Pizza {
        System.out.println("Time to delivery is " + this.getStatus().getTimeToDelivery() + " days");
    }

-    public static List<Pizza> getAllUndeliveredPizza(List<Pizza> input) {
-        List<Pizza> undelivered = input;
-        CollectionUtils.filter(undelivered, thatAreNotDelivered());
-        return undelivered;
+    public static List<Pizza> getAllUndeliveredPizzas(List<Pizza> input) {
+        return input.stream().filter(
+                (s) -> undeliveredPizzaStatuses.contains(s.getStatus()))
+                .collect(Collectors.toList());
    }

-    public static EnumMap<PizzaStatusEnum, List<Pizza>> groupPizzaByStatus(List<Pizza> pizzaList) {
-        EnumMap<PizzaStatusEnum, List<Pizza>> pzByStatus = new EnumMap<PizzaStatusEnum, List<Pizza>>(PizzaStatusEnum.class);
-        for (Pizza pz : pizzaList) {
-            PizzaStatusEnum status = pz.getStatus();
-
-            if (pzByStatus.containsKey(status)) {
-                pzByStatus.get(status).add(pz);
-            } else {
-                List<Pizza> newPzList = new ArrayList<Pizza>();
-                newPzList.add(pz);
-                pzByStatus.put(status, newPzList);
-            }
-        }
-        return pzByStatus;
+    public static EnumMap<PizzaStatus, List<Pizza>>
+    groupPizzaByStatus(List<Pizza> pzList) {
+        return pzList.stream().collect(
+                Collectors.groupingBy(Pizza::getStatus,
+                        () -> new EnumMap<>(PizzaStatus.class), Collectors.toList()));
    }

    public void deliver() {
        if (isDeliverable()) {
            PizzaDeliverySystemConfiguration.getInstance().getDeliveryStrategy().deliver(this);
-            this.setStatus(PizzaStatusEnum.DELIVERED);
+            this.setStatus(PizzaStatus.DELIVERED);
        }
    }

@@ -108,10 +105,6 @@ public class Pizza {
    }

    private static Predicate<Pizza> thatAreNotDelivered() {
-        return new Predicate<Pizza>() {
-            public boolean evaluate(Pizza entry) {
-                return undeliveredPizzaStatuses.contains(entry.getStatus());
-            }
-        };
+        return entry -> undeliveredPizzaStatuses.contains(entry.getStatus());
    }
 }
@@ -1,9 +1,10 @@
 package com.baeldung.enums;

 public enum PizzaDeliverySystemConfiguration {
-    INSTANCE ;
-    private PizzaDeliverySystemConfiguration() {
-        //Do the configuration initialization which
+    INSTANCE;
+
+    PizzaDeliverySystemConfiguration() {
+        // Do the configuration initialization which
        // involves overriding defaults like delivery strategy
    }

@@ -31,7 +31,7 @@ public class JavaCollectionConversionUnitTest {

    @Test
    public final void givenUsingCoreJava_whenListConvertedToArray_thenCorrect() {
-        final List<Integer> sourceList = Lists.<Integer> newArrayList(0, 1, 2, 3, 4, 5);
+        final List<Integer> sourceList = Arrays.asList(0, 1, 2, 3, 4, 5);
        final Integer[] targetArray = sourceList.toArray(new Integer[sourceList.size()]);
    }

--- a/Show More
+++ b/Show More