diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/WsConnection.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/WsConnection.kt index 197fd056..a6befbc0 100644 --- a/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/WsConnection.kt +++ b/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/WsConnection.kt @@ -165,7 +165,8 @@ open class WsConnection( reconnecting.set(false) connectInternal() }, - retryInterval, TimeUnit.MILLISECONDS + retryInterval, + TimeUnit.MILLISECONDS ) } @@ -298,7 +299,10 @@ open class WsConnection( fun onRpc(msg: ResponseWSParser.WsResponse): Mono { return if (msg.id.isNumber()) { val resp = JsonRpcResponse( - msg.value, msg.error, msg.id, null + msg.value, + msg.error, + msg.id, + null ) Mono.fromCallable { val status = rpcReceive.tryEmitNext(resp)