Sha256: 090ce128ea988f8256396f524831f7a7b204396bf972161ec61757b8b633b61a
Contents?: true
Size: 933 Bytes
Versions: 4
Compression:
Stored size: 933 Bytes
Contents
require 'active_support' module LHC module BasicMethods extend ActiveSupport::Concern module ClassMethods def request(options) if options.is_a? Array parallel_requests(options) else LHC::Request.new(options).response end end [:get, :post, :put, :delete].each do |http_method| define_method(http_method) do |url, options = {}| request(options.merge( url: url, method: http_method )) end end private def parallel_requests(options) hydra = Typhoeus::Hydra.hydra requests = [] options.each do |option| request = LHC::Request.new(option, false) requests << request hydra.queue request.raw unless request.response.present? end hydra.run requests.map(&:response) end end end end
Version data entries
4 entries across 4 versions & 1 rubygems