Multiple Requests Example

consumer-with-channels.cr

require "HTTP"

API_BASE_URL = "http://localhost:9200"

start = Time.now.epoch_ms()

channel = Channel({Int32, String}).new

["/one", "/two", "/three"].each_with_index do |endpoint, index|
  spawn do
    channel.send({index, HTTP::Client.get(API_BASE_URL + endpoint).body})
  end
end

puts [channel.receive(), channel.receive(), channel.receive()].sort { |a, b| a <=> b }.map { |el| el[1] }
puts "Completed in " + (Time.now.epoch_ms() - start).to_s + " ms"

consumer-with-futures.cr

require "http/client"

API_BASE_URL = "http://localhost:9200"

start = Time.now.epoch_ms()

results = ["/one","/two","/three"].map do |endpoint|
  future do
    HTTP::Client.get("#{API_BASE_URL}#{endpoint}").body
  end
end.map(&.get)

puts results
puts "Completed in " + (Time.now.epoch_ms() - start).to_s + " ms"