From 11fae77b35ec8e98bc000689e17aab4dd1211a6a Mon Sep 17 00:00:00 2001 From: Yury-Fridlyand Date: Mon, 18 Dec 2023 18:17:06 -0800 Subject: [PATCH] Typo fix. Signed-off-by: Yury-Fridlyand --- .../java/babushka/connectors/handlers/CallbackDispatcher.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/java/client/src/main/java/babushka/connectors/handlers/CallbackDispatcher.java b/java/client/src/main/java/babushka/connectors/handlers/CallbackDispatcher.java index a1782e7fe8..75b17e39d3 100644 --- a/java/client/src/main/java/babushka/connectors/handlers/CallbackDispatcher.java +++ b/java/client/src/main/java/babushka/connectors/handlers/CallbackDispatcher.java @@ -65,7 +65,7 @@ public CompletableFuture registerConnection() { public void completeRequest(Response response) { // A connection response doesn't contain a callback id int callbackId = - clientState.isInitializing() ? response.getCallbackIdx() : CONNECTION_PROMISE_ID; + clientState.isInitializing() ? CONNECTION_PROMISE_ID : response.getCallbackIdx(); CompletableFuture future = responses.get(callbackId); if (future != null) { future.completeAsync(() -> response);