gistfile1.rb

clients = []
message_queue = []

# entrypoint websocketa
def incoming_request(connection)
  clients.push(connection)
end

Thread.new do
  while x = message_queue.shift
    clients.each { send_message(client, x) }
  end
end

# web appka gdzieś, podczas requestu:
message_queue.push("mleko")