WIP

Author: tomekowal

lib/tesla/adapter/hackney.ex

@@ -52,6 +52,12 @@ if Code.ensure_loaded?(:hackney) do
     # Convert cacertfile to cacerts to fix SSL with custom CA certificates
     if Version.match?(@hackney_version, "~> 3.0") do
       defp process_options(opts) do
+        opts
+        |> process_ssl_options()
+        |> process_timeout_options()
+      end
+
+      defp process_ssl_options(opts) do
         case Keyword.get(opts, :ssl_options) do
           nil ->
             opts
@@ -77,6 +83,19 @@ if Code.ensure_loaded?(:hackney) do
             end
         end
       end
+
+      defp process_timeout_options(opts) do
+        # Hackney 3.X pools connections with their original recv_timeout.
+        # If user specifies a short timeout (<= 1000ms), disable pooling to ensure it's respected.
+        # This is necessary because pooled connections can't have their timeout updated.
+        case Keyword.get(opts, :recv_timeout) do
+          timeout when is_integer(timeout) and timeout <= 1000 ->
+            Keyword.put_new(opts, :pool, false)
+
+          _ ->
+            opts
+        end
+      end
     else
       defp process_options(opts), do: opts
     end
@@ -159,10 +178,11 @@ if Code.ensure_loaded?(:hackney) do
 
     if Version.match?(@hackney_version, "~> 3.0") do
       # Hackney 3.x: for streaming requests, :hackney.start_response returns handle as PID
-      # Must use :hackney_conn.body/1 to read body (max_body deprecated in 3.x)
-      defp handle({:ok, status, headers, handle}, _opts)
+      # Must use :hackney_conn.body/2 to read body with timeout
+      defp handle({:ok, status, headers, handle}, opts)
            when is_hackney_connection_handle(handle) do
-        with {:ok, body} <- :hackney_conn.body(handle) do
+        timeout = Keyword.get(opts, :recv_timeout, :infinity)
+        with {:ok, body} <- :hackney_conn.body(handle, timeout) do
           {:ok, status, headers, body}
         end
       end

test/tesla/adapter/hackney_test.exs

@@ -43,8 +43,7 @@ defmodule Tesla.Adapter.HackneyTest do
       body: "test"
     }
 
-    # Disable connection pooling to ensure timeout is properly enforced
-    assert {:error, :timeout} = call(request, recv_timeout: 100, pool: false)
+    assert {:error, :timeout} = call(request, recv_timeout: 100)
   end
 
   test "stream request body: error" do