diff --git a/example/pom.xml b/example/pom.xml index 4b62665..90463d4 100644 --- a/example/pom.xml +++ b/example/pom.xml @@ -34,7 +34,7 @@ it.tdlight tdlight-java-bom - 2.8.5.1 + 2.8.5.2 pom import diff --git a/src/main/java/it/tdlight/common/internal/InternalReactiveClient.java b/src/main/java/it/tdlight/common/internal/InternalReactiveClient.java index 13dec7f..b353f7d 100644 --- a/src/main/java/it/tdlight/common/internal/InternalReactiveClient.java +++ b/src/main/java/it/tdlight/common/internal/InternalReactiveClient.java @@ -262,11 +262,11 @@ public final class InternalReactiveClient implements ClientEventsHandler, Reacti public void setListener(SignalListener listener) { logger.debug(TG_MARKER, "Setting handler of client {}", clientId); - var prevSignalListener = this.signalListener; + SignalListener prevSignalListener = this.signalListener; if (!(prevSignalListener instanceof ReplayStartupUpdatesListener)) { throw new IllegalStateException("Already subscribed"); } - var replayStartupUpdatesListener = (ReplayStartupUpdatesListener) prevSignalListener; + ReplayStartupUpdatesListener replayStartupUpdatesListener = (ReplayStartupUpdatesListener) prevSignalListener; // Set the new listener into the startup listener, then drain its startup queue replayStartupUpdatesListener.setNewListener(listener); replayStartupUpdatesListener.drain();