Contents

require 'celluloid'
require 'celluloid/notifications'

module Hokaido
  class Watcher
    include Celluloid
    include Celluloid::Notifications

    def initialize(socket)
      @socket = socket

      subscribe 'broadcast', :received
    end

    def received(topic, chunk)
      @socket.write chunk
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
hokaido-0.0.7	lib/hokaido/watcher.rb
hokaido-0.0.6	lib/hokaido/watcher.rb
hokaido-0.0.5	lib/hokaido/watcher.rb