Delete outdated test

Author: tzolov

spring-ai-mcp-core/src/main/java/org/springframework/ai/mcp/client/stdio/StdioServerTransport.java

@@ -58,8 +58,6 @@ public class StdioServerTransport extends AbstractMcpTransport {
 
 	private Scheduler errorScheduler;
 
-	volatile boolean isRunning;
-
 	private final ServerParameters params;
 
 	public StdioServerTransport(ServerParameters params) {
@@ -112,7 +110,6 @@ public void start() {
 		}
 
 		// Start threads
-		this.isRunning = true;
 		startInboundProcessing();
 		startOutboundProcessing();
 		startErrorProcessing();
@@ -136,7 +133,7 @@ private void startErrorProcessing() {
 			try (BufferedReader processErrorReader = new BufferedReader(
 					new InputStreamReader(process.getErrorStream()))) {
 				String line;
-				while (isRunning && processErrorReader != null && (line = processErrorReader.readLine()) != null) {
+				while ((line = processErrorReader.readLine()) != null) {
 					try {
 						System.out.println("Received error line: " + line);
 						// TODO: handle errors, etc.
@@ -148,12 +145,7 @@ private void startErrorProcessing() {
 				}
 			}
 			catch (IOException e) {
-				if (this.isRunning) {
-					throw new RuntimeException(e);
-				}
-			}
-			finally {
-				this.isRunning = false;
+				throw new RuntimeException(e);
 			}
 		});
 	}
@@ -162,7 +154,7 @@ private void startInboundProcessing() {
 		this.inboundScheduler.schedule(() -> {
 			try (BufferedReader processReader = new BufferedReader(new InputStreamReader(process.getInputStream()))) {
 				String line;
-				while (this.isRunning && processReader != null && (line = processReader.readLine()) != null) {
+				while ((line = processReader.readLine()) != null) {
 					try {
 						JSONRPCMessage message = deserializeJsonRpcMessage(line);
 						if (!this.getInboundSink().tryEmitNext(message).isSuccess()) {
@@ -176,12 +168,7 @@ private void startInboundProcessing() {
 				}
 			}
 			catch (IOException e) {
-				if (isRunning) {
-					throw new RuntimeException(e);
-				}
-			}
-			finally {
-				isRunning = false;
+				throw new RuntimeException(e);
 			}
 		});
 	}
@@ -230,8 +217,6 @@ private void startOutboundProcessing() {
 	@Override
 	public Mono<Void> closeGracefully() {
 
-		this.isRunning = false;
-
 		return Mono.fromFuture(() -> {
 			System.out.println("Sending TERM to process");
 			if (this.process != null) {