Fixes after update to v5.4

Author: osipxd

Diff for: ktor-client/ktor-client-apache5/jvm/src/io/ktor/client/engine/apache5/Apache5Engine.kt

@@ -1,5 +1,5 @@
 /*
- * Copyright 2014-2022 JetBrains s.r.o and contributors. Use of this source code is governed by the Apache 2.0 license.
+ * Copyright 2014-2025 JetBrains s.r.o and contributors. Use of this source code is governed by the Apache 2.0 license.
  */
 
 package io.ktor.client.engine.apache5
@@ -9,19 +9,23 @@ import io.ktor.client.plugins.*
 import io.ktor.client.plugins.sse.*
 import io.ktor.client.request.*
 import io.ktor.utils.io.*
-import kotlinx.coroutines.*
-import org.apache.hc.client5.http.config.*
-import org.apache.hc.client5.http.impl.async.*
-import org.apache.hc.client5.http.impl.nio.*
-import org.apache.hc.client5.http.ssl.*
-import org.apache.hc.core5.http.*
-import org.apache.hc.core5.http.ssl.*
-import org.apache.hc.core5.io.*
-import org.apache.hc.core5.reactor.*
-import org.apache.hc.core5.ssl.*
-import org.apache.hc.core5.util.*
-import java.net.*
-import java.util.concurrent.*
+import kotlinx.coroutines.Job
+import org.apache.hc.client5.http.config.ConnectionConfig
+import org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient
+import org.apache.hc.client5.http.impl.async.HttpAsyncClientBuilder
+import org.apache.hc.client5.http.impl.async.HttpAsyncClients
+import org.apache.hc.client5.http.impl.nio.PoolingAsyncClientConnectionManagerBuilder
+import org.apache.hc.client5.http.ssl.ClientTlsStrategyBuilder
+import org.apache.hc.client5.http.ssl.HostnameVerificationPolicy
+import org.apache.hc.core5.http.HttpHost
+import org.apache.hc.core5.http.ssl.TLS
+import org.apache.hc.core5.io.CloseMode
+import org.apache.hc.core5.reactor.IOReactorConfig
+import org.apache.hc.core5.ssl.SSLContexts
+import org.apache.hc.core5.util.Timeout
+import java.net.InetSocketAddress
+import java.net.Proxy
+import java.util.concurrent.TimeUnit
 
 private const val MAX_CONNECTIONS_COUNT = 1000
 private const val IO_THREAD_COUNT_DEFAULT = 4
@@ -89,6 +93,8 @@ internal class Apache5Engine(override val config: Apache5EngineConfig) : HttpCli
                             ClientTlsStrategyBuilder.create()
                                 .setSslContext(config.sslContext ?: SSLContexts.createSystemDefault())
                                 .setTlsVersions(TLS.V_1_3, TLS.V_1_2)
+                                // TODO: Remove apply after https://github.com/apache/httpcomponents-client/pull/588 merged
+                                .apply { setHostnameVerificationPolicy(HostnameVerificationPolicy.BOTH) }
                                 .build()
                         )
                         .setDefaultConnectionConfig(

Diff for: ktor-client/ktor-client-apache5/jvm/src/io/ktor/client/engine/apache5/ApacheResponseConsumer.kt

@@ -1,22 +1,27 @@
 /*
- * Copyright 2014-2022 JetBrains s.r.o and contributors. Use of this source code is governed by the Apache 2.0 license.
+ * Copyright 2014-2025 JetBrains s.r.o and contributors. Use of this source code is governed by the Apache 2.0 license.
  */
 
 package io.ktor.client.engine.apache5
 
 import io.ktor.client.request.*
 import io.ktor.util.*
 import io.ktor.utils.io.*
-import kotlinx.atomicfu.*
+import kotlinx.atomicfu.atomic
 import kotlinx.coroutines.*
-import kotlinx.coroutines.channels.*
+import kotlinx.coroutines.channels.Channel
 import kotlinx.coroutines.channels.Channel.Factory.UNLIMITED
-import org.apache.hc.core5.concurrent.*
-import org.apache.hc.core5.http.*
-import org.apache.hc.core5.http.nio.*
-import org.apache.hc.core5.http.protocol.*
-import java.nio.*
-import kotlin.coroutines.*
+import org.apache.hc.core5.concurrent.CallbackContribution
+import org.apache.hc.core5.concurrent.FutureCallback
+import org.apache.hc.core5.http.EntityDetails
+import org.apache.hc.core5.http.Header
+import org.apache.hc.core5.http.HttpResponse
+import org.apache.hc.core5.http.nio.AsyncEntityConsumer
+import org.apache.hc.core5.http.nio.AsyncResponseConsumer
+import org.apache.hc.core5.http.nio.CapacityChannel
+import org.apache.hc.core5.http.protocol.HttpContext
+import java.nio.ByteBuffer
+import kotlin.coroutines.CoroutineContext
 
 private object CloseChannel
 
@@ -28,8 +33,8 @@ internal class BasicResponseConsumer(private val dataConsumer: ApacheResponseCon
     override fun consumeResponse(
         response: HttpResponse,
         entityDetails: EntityDetails?,
-        httpContext: HttpContext,
-        resultCallback: FutureCallback<Unit>
+        context: HttpContext?,
+        resultCallback: FutureCallback<Unit>,
     ) {
         responseDeferred.complete(response)
         if (entityDetails != null) {