From a1312e9ce01545f13ffb3068c873c9b43530ae42 Mon Sep 17 00:00:00 2001
From: Dotun Kola-Olaleye <dotunkolaolaleye@gmail.com>
Date: Thu, 2 Feb 2017 18:30:05 +0100
Subject: [PATCH] Custom Thread Pools In Java 8 Parallel Streams (#1088)

* String to char array and char array to String.

* Method change

* Custom ThreadPool In Java 8 Parallel Streams

* Implemented suggested edits from editor.

* Broke long method signature

* Changed primitive type int to long and formula.

* Update wrapper type to Long
---
 .../baeldung/java/streams/ThreadPoolInParallelStream.java | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/core-java/src/test/java/org/baeldung/java/streams/ThreadPoolInParallelStream.java b/core-java/src/test/java/org/baeldung/java/streams/ThreadPoolInParallelStream.java
index fdf593ba64..b8c0991b8d 100644
--- a/core-java/src/test/java/org/baeldung/java/streams/ThreadPoolInParallelStream.java
+++ b/core-java/src/test/java/org/baeldung/java/streams/ThreadPoolInParallelStream.java
@@ -1,5 +1,5 @@
 package org.baeldung.java.streams;
-
+
 import org.junit.Test;
 
 import java.util.ArrayList;
@@ -17,18 +17,18 @@ public class ThreadPoolInParallelStream {
     
     @Test
     public void giveRangeOfLongs_whenSummedInParallel_shouldBeEqualToExpectedTotal() 
-        throws InterruptedException, ExecutionException {
+      throws InterruptedException, ExecutionException {
         long firstNum = 1;
         long lastNum = 1_000_000;
 
-        List<Long> aList = LongStream.range(firstNum, lastNum).boxed()
+        List<Long> aList = LongStream.rangeClosed(firstNum, lastNum).boxed()
           .collect(Collectors.toList());
 
         ForkJoinPool customThreadPool = new ForkJoinPool(4);
         long actualTotal = customThreadPool.submit(() -> aList.parallelStream()
           .reduce(0L, Long::sum)).get();
         
-        assertEquals((lastNum + firstNum) * lastNum / 2, actualTotal);
+        assertEquals((lastNum + firstNum) * lastNum / 2, actualTotal);
     }
     
     @Test