From d5b981a0bb5920f542ca7bffde5f65ddab9da787 Mon Sep 17 00:00:00 2001
From: HoneyryderChuck <cardoso_tiago@hotmail.com>
Date: Tue, 12 Dec 2017 21:23:52 +0000
Subject: [PATCH] io: #build_socket as factory; re-building it in connect if
 closed (for when the server closes the socket)

---
 lib/httpx/io.rb | 17 +++++++++++++++--
 1 file changed, 15 insertions(+), 2 deletions(-)

diff --git a/lib/httpx/io.rb b/lib/httpx/io.rb
index 7273a187..b727fc37 100644
--- a/lib/httpx/io.rb
+++ b/lib/httpx/io.rb
@@ -15,7 +15,6 @@ module HTTPX
       @uri = uri
       @ip = TCPSocket.getaddress(@uri.host) 
       @port = @uri.port
-      addr = IPAddr.new(@ip)
       if options.io
         @io = case options.io
         when Hash
@@ -25,7 +24,7 @@ module HTTPX
         end
         @keep_open = !@io.nil?
       end
-      @io ||= Socket.new(addr.family, :STREAM, 0)
+      @io ||= build_socket 
     end
 
     def to_io
@@ -39,10 +38,12 @@ module HTTPX
     def connect
       return if @connected || @keep_open
       begin
+        @io = build_socket if @io.closed?
         @io.connect_nonblock(Socket.sockaddr_in(@port, @ip))
       rescue Errno::EISCONN
       end
       @connected = true
+      log { "connected" }
 
     rescue Errno::EINPROGRESS,
            Errno::EALREADY,
@@ -95,6 +96,18 @@ module HTTPX
     def closed?
       !@keep_open && !@connected
     end
+
+    private
+
+    def build_socket
+      addr = IPAddr.new(@ip)
+      Socket.new(addr.family, :STREAM, 0)
+    end
+    
+    def log(&msg)
+      return unless $HTTPX_DEBUG
+      $stderr << (+"io: " << msg.call << "\n")
+    end
   end
 
   class SSL < TCP