streaming

require 'set'
require 'json'

class Broadcaster
  def initialize
    @mutex = Mutex.new

package main

import (
	"log"
	"net/http"
	"time"