lib/httpx/client.rb in httpx-0.0.5 vs lib/httpx/client.rb in httpx-0.1.0

@@ -49,16 +49,10 @@
       stream.refuse
       # TODO: policy for handling promises
     end
 
     def fetch_response(request)
-      response = @responses.delete(request)
-      if response.is_a?(ErrorResponse) && response.retryable?
-        channel = find_channel(request)
-        channel.send(request, retries: response.retries - 1)
-        return
-      end
-      response
+      @responses.delete(request)
     end
 
     def find_channel(request, **options)
       uri = URI(request.uri)
       @connection.find_channel(uri) || begin