Update tests.

Author: gk-brown

kilo-client/src/test/java/org/httprpc/kilo/util/concurrent/PipeTest.java

@@ -14,8 +14,6 @@
 
 package org.httprpc.kilo.util.concurrent;
 
-import org.junit.jupiter.api.AfterAll;
-import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.Test;
 
 import java.util.concurrent.ExecutorService;
@@ -25,17 +23,7 @@
 import static org.junit.jupiter.api.Assertions.*;
 
 public class PipeTest {
-    private static ExecutorService executorService = null;
-
-    @BeforeAll
-    public static void setUpClass() {
-        executorService = Executors.newSingleThreadExecutor();
-    }
-
-    @AfterAll
-    public static void tearDownClass() {
-        executorService.shutdown();
-    }
+    private static ExecutorService executorService = Executors.newSingleThreadExecutor();
 
     @Test
     public void testBoundedPipe() {

kilo-test/src/main/java/org/httprpc/kilo/test/EmployeeService.java

@@ -14,7 +14,6 @@
 
 package org.httprpc.kilo.test;
 
-import jakarta.servlet.ServletException;
 import jakarta.servlet.annotation.WebServlet;
 import org.httprpc.kilo.RequestMethod;
 import org.httprpc.kilo.ResourcePath;
@@ -33,27 +32,13 @@
 
 @WebServlet(urlPatterns = {"/employees/*"}, loadOnStartup = 1)
 public class EmployeeService extends WebService {
-    private static ExecutorService executorService = null;
+    private static ExecutorService executorService = Executors.newCachedThreadPool();
 
     @Override
     protected String getDataSourceName() {
         return "java:comp/env/jdbc/EmployeeDB";
     }
 
-    @Override
-    public void init() throws ServletException {
-        super.init();
-
-        executorService = Executors.newCachedThreadPool();
-    }
-
-    @Override
-    public void destroy() {
-        executorService.shutdown();
-
-        super.destroy();
-    }
-
     @RequestMethod("GET")
     public Iterable<Employee> getEmployees(boolean stream) throws SQLException {
         return stream ? getEmployeesStream() : getEmployeesList();