streaming_blocking.cr

require "http/server"

server = HTTP::Server.new "0.0.0.0", 8080 do |context|
  context.response.headers["Content-Type"] = "text/event-stream"
  stream_channel = Channel(String).new
  spawn do
    loop do
      sleep 0.1
      stream_channel.send "Hello World"
    end
  end
  loop do
    context.response.puts(stream_channel.receive)
    context.response.flush
  end
end

puts "Listening on http://0.0.0.0:8080"
server.listen