Use a simple break instead of EOFException

polypheny · Mar 28, 2024 · d14b95d · d14b95d
1 parent d515b45
commit d14b95d
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/plugins/proto-interface/src/main/java/org/polypheny/db/protointerface/PIService.java b/plugins/proto-interface/src/main/java/org/polypheny/db/protointerface/PIService.java
@@ -21,6 +21,7 @@
 import java.util.LinkedList;
 import java.util.List;
 import java.util.Optional;
+import java.util.Queue;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ExecutionException;
 import lombok.extern.slf4j.Slf4j;
@@ -195,7 +196,7 @@ private void handleMessages() throws IOException, ExecutionException, Interrupte
             return;
         }
 
-        LinkedList<Request> waiting = new LinkedList<>();
+        Queue<Request> waiting = new LinkedList<>();
         CompletableFuture<Request> request = waitForRequest();
         CompletableFuture<Response> response = null;
         Thread handle = null;
@@ -225,7 +226,7 @@ private void handleMessages() throws IOException, ExecutionException, Interrupte
                     handle = null;
                     Response r = response.get();
                     if ( r.getTypeCase() == Response.TypeCase.DISCONNECT_RESPONSE ) {
-                        throw new EOFException();
+                        break;
                     }
                     response = null;
                 }