request_with_timeouts.rb

#!/usr/bin/env ruby

require 'async'
require 'async/http/internet'

Async do |task|
	internet = Async::HTTP::Internet.new
	
	# Effectively a connection timeout:
	response = task.with_timeout(10) do
		internet.get("https://www.google.com/search?q=things")
	end
	
	# Effectively a read timeout:
	task.with_timeout(1) do |timer|
		while chunk = response.read
			timer.reset
			
			# Process chunk.
			puts chunk.inspect
		end
	end
ensure
	internet.close
end

Something like this?

      def optional_timeout(task, timeout)
        if timeout
          task.timeout(timeout) { yield }
        else
          yield
        end
      end

      response = optional_timeout(task, connect_timeout) { request_client.call(request) }
      body = optional_timeout(task, env.timeout) { response.read }