Reuse TCP connections

lib/segment/analytics/request.rb

@@ -112,6 +112,11 @@ def send_request(write_key, batch)
 
           [200, '{}']
         else
+          # If `start` is not called, Ruby adds a 'Connection: close' header to
+          # all requests, preventing us from reusing a connection for multiple
+          # HTTP requests
+          @http.start unless @http.started?
+
           response = @http.request(request, payload)
           [response.code.to_i, response.body]
         end

lib/segment/analytics/worker.rb

@@ -28,6 +28,7 @@ def initialize(queue, write_key, options = {})
         @on_error = options[:on_error] || proc { |status, error| }
         @batch = []
         @lock = Mutex.new
+        @request = Request.new
       end
 
       # public: Continuously runs the loop to check for new events
@@ -42,8 +43,7 @@ def run
             end
           end
 
-          res = Request.new.post @write_key, @batch
-
+          res = @request.post(@write_key, @batch)
           @on_error.call(res.status, res.error) unless res.status == 200
 
           @lock.synchronize { @batch.clear }