http_helpers.rb in pubsubstub-0.2.2

- old
+ new

@@ -2,11 +2,11 @@
 
 module HTTPHelpers
   def async_get(uri, headers = {}, retries: 10, &block)
     uri = URI(uri.to_s)
     queue = Queue.new
-    Thread.start do
+    thread = Thread.start do
       begin
         Net::HTTP.start(uri.host, uri.port, open_timeout: 10) do |http|
           request = Net::HTTP::Get.new uri.request_uri
           headers.each do |name, value|
             request.add_field(name, value)
@@ -31,10 +31,10 @@
       rescue Errno::ECONNRESET, Errno::EPIPE
         # The server closed the connection
       end
     end
 
-    queue
+    return queue, thread
   end
 
   ROOT_PATH = File.join(__dir__, '../..')
   LOG_DIR = File.join(ROOT_PATH, 'tmp')
   LOG_PATH = File.join(ROOT_PATH, 'tmp/puma.log')