clean

Signed-off-by: Christian Tzolov <christian.tzolov@broadcom.com>

Author: tzolov

mcp/src/main/java/io/modelcontextprotocol/client/transport/HttpClientSseClientTransport.java

@@ -330,13 +330,12 @@ protected Flux<ResponseSubscribers.SseResponseEvent> eventStream() {
 			.GET()
 			.build();
 
-		Flux<ResponseSubscribers.SseResponseEvent> bla = Flux.<ResponseEvent>create(sseSink -> this.httpClient
+		return Flux.<ResponseEvent>create(sseSink -> this.httpClient
 			.sendAsync(request, responseInfo -> ResponseSubscribers.sseToBodySubscriber(responseInfo, sseSink))
 			.exceptionallyCompose(e -> {
 				sseSink.error(e);
 				return CompletableFuture.failedFuture(e);
 			})).map(responseEvent -> (ResponseSubscribers.SseResponseEvent) responseEvent);
-		return bla;
 	}
 
 	@Override