Skip to content

Commit

Permalink
fix other checkstyle warnings
Browse files Browse the repository at this point in the history
Signed-off-by: Lachlan Roberts <[email protected]>
  • Loading branch information
lachlan-roberts committed May 29, 2024
1 parent 19215d4 commit 364183c
Showing 1 changed file with 4 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@

import java.io.IOException;
import java.net.URI;
import java.util.Objects;
import java.util.concurrent.atomic.AtomicReference;

import org.eclipse.jetty.client.Request;
Expand Down Expand Up @@ -79,7 +80,7 @@ public Mono<Void> execute(URI url, @Nullable HttpHeaders headers, WebSocketHandl
headers.keySet().forEach(header -> upgradeRequest.setHeader(header, headers.getValuesAsList(header)));
}

AtomicReference<HandshakeInfo> handshakeInfo = new AtomicReference<>();
final AtomicReference<HandshakeInfo> handshakeInfo = new AtomicReference<>();
JettyUpgradeListener jettyUpgradeListener = new JettyUpgradeListener() {
@Override
public void onHandshakeResponse(Request request, Response response) {
Expand All @@ -92,10 +93,10 @@ public void onHandshakeResponse(Request request, Response response) {

Sinks.Empty<Void> completion = Sinks.empty();
JettyWebSocketHandlerAdapter handlerAdapter = new JettyWebSocketHandlerAdapter(handler, session ->
new JettyWebSocketSession(session, handshakeInfo.get(), DefaultDataBufferFactory.sharedInstance, completion));
new JettyWebSocketSession(session, Objects.requireNonNull(handshakeInfo.get()), DefaultDataBufferFactory.sharedInstance, completion));
try {
this.client.connect(handlerAdapter, url, upgradeRequest, jettyUpgradeListener)
.exceptionally((throwable) -> {
.exceptionally(throwable -> {
// Only fail the completion if we have an error
// as the JettyWebSocketSession will never be opened.
completion.tryEmitError(throwable);
Expand Down

0 comments on commit 364183c

Please sign in to comment.