Skip to content

Commit f72e92b

Browse files
committed
fix format
1 parent e153034 commit f72e92b

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

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

+3-3
Original file line numberDiff line numberDiff line change
@@ -338,8 +338,8 @@ public Mono<Void> connect(Function<Mono<JSONRPCMessage>, Mono<JSONRPCMessage>> h
338338
}
339339

340340
private void subscribeSse(final Function<Mono<JSONRPCMessage>, Mono<JSONRPCMessage>> handler, MonoSink<Void> sink) {
341-
final URI clientUri = Utils.resolveUri(this.baseUri, this.sseEndpoint);
342-
sseClient.subscribe(clientUri.toString(), new FlowSseClient.SseEventHandler() {
341+
final URI clientUri = Utils.resolveUri(this.baseUri, this.sseEndpoint);
342+
sseClient.subscribe(clientUri.toString(), new FlowSseClient.SseEventHandler() {
343343
@Override
344344
public void onEvent(SseEvent event) {
345345
if (state.get() == TransportState.CLOSING || state.get() == TransportState.DISCONNECTED) {
@@ -413,7 +413,7 @@ private Mono<String> serializeMessage(final JSONRPCMessage message) {
413413
}
414414

415415
private Mono<HttpResponse<Void>> sendHttpPost(final String endpoint, final String body) {
416-
final URI requestUri = Utils.resolveUri(baseUri, endpoint);
416+
final URI requestUri = Utils.resolveUri(baseUri, endpoint);
417417
final HttpRequest request = requestBuilder.uri(requestUri)
418418
.POST(HttpRequest.BodyPublishers.ofString(body))
419419
.build();

0 commit comments

Comments
 (0)