Make nullable

drpcorg · Sep 25, 2024 · 1e54f08 · 1e54f08
1 parent 109f282
commit 1e54f08
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/GenericWsHead.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/GenericWsHead.kt
@@ -65,7 +65,7 @@ class GenericWsHead(
     }
     private val chainIdValidator = chainSpecific.chainSettingsValidator(upstream.getChain(), upstream, jsonRpcWsClient)
 
-    private val connectionId = AtomicReference("")
+    private val connectionId = AtomicReference<String?>(null)
     private val subscribed = AtomicBoolean(false)
     private val connected = AtomicBoolean(false)
     private val isSyncing = AtomicBoolean(false)
@@ -186,7 +186,7 @@ class GenericWsHead(
                     headLivenessSink.emitNext(HeadLivenessState.DISCONNECTED) { _, res -> res == Sinks.EmitResult.FAIL_NON_SERIALIZED }
                     subscribed.set(false)
                     connected.set(false)
-                    connectionId.set("")
+                    connectionId.set(null)
                 } else if (it.connectionState == WsConnection.ConnectionState.CONNECTED) {
                     connected.set(true)
                     return@map true