test: add parallel execution mode tests

Verify that processCommand() works correctly in parallel mode
(serialExecution=false): command executes synchronously on the
calling thread, response is published to the session, and exceptions
are handled without publishing a response.

Made-with: Cursor

Author: haiyang.zhou

src/test/java/com/github/tonivade/resp/RespServerContextTest.java

@@ -159,6 +159,34 @@ public void requireCallback() {
     assertThrows(IllegalArgumentException.class, () -> new RespServerContext(HOST, PORT, null));
   }
 
+  @Test
+  public void processCommandParallelMode() {
+    var parallelContext = new RespServerContext(HOST, PORT, commands,
+        SessionListener.nullListener(), false);
+    Request request = new DefaultRequest(parallelContext, session, safeString("test"), Collections.emptyList());
+    when(commands.getCommand(request.getCommand())).thenReturn(respCommand);
+    when(respCommand.execute(request)).thenReturn(nullString());
+
+    parallelContext.processCommand(request);
+
+    verify(respCommand).execute(request);
+    verify(session).publish(nullString());
+  }
+
+  @Test
+  public void processCommandParallelModeException() {
+    var parallelContext = new RespServerContext(HOST, PORT, commands,
+        SessionListener.nullListener(), false);
+    Request request = new DefaultRequest(parallelContext, session, safeString("test"), Collections.emptyList());
+    when(commands.getCommand(request.getCommand())).thenReturn(respCommand);
+    doThrow(RuntimeException.class).when(respCommand).execute(request);
+
+    parallelContext.processCommand(request);
+
+    verify(respCommand).execute(request);
+    verify(session, times(0)).publish(any());
+  }
+
   private Request newRequest(String command) {
     return new DefaultRequest(serverContext, session, safeString(command), Collections.emptyList());
   }