bg.rb

require 'angelo'

class BG < Angelo::Base

  websocket '/' do |ws|
    websockets << ws
  end

end

class Worker
  include Celluloid

  def run
    @n = 1

    every 1 do
      @n += 1
      n = @n.to_s
      BG.websockets.each {|ws| ws.write n}
    end
  end

end

Worker.new.async.run
BG.run!