Skip to content

Commit cf02a57

Browse files
committed
Remove subscription null check as the subscription can not be null
Signed-off-by: Dariusz Jędrzejczyk <dariusz.jedrzejczyk@broadcom.com>
1 parent 7315a53 commit cf02a57

File tree

1 file changed

+2
-6
lines changed

1 file changed

+2
-6
lines changed

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

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -123,16 +123,12 @@ public SseLineSubscriber(ResponseInfo responseInfo, FluxSink<ResponseEvent> sink
123123
protected void hookOnSubscribe(Subscription subscription) {
124124

125125
sink.onRequest(n -> {
126-
if (subscription != null) {
127-
subscription.request(n);
128-
}
126+
subscription.request(n);
129127
});
130128

131129
// Register disposal callback to cancel subscription when Flux is disposed
132130
sink.onDispose(() -> {
133-
if (subscription != null) {
134-
subscription.cancel();
135-
}
131+
subscription.cancel();
136132
});
137133
}
138134

0 commit comments

Comments
 (0)