gistfile1.rb

module Sullivans
  class UserActor
    include Celluloid
    include Celluloid::Notifications
    include Celluloid::Logger
 
    def initialize(socket)
      # Subscribe to conversations
      info "Started a client"

      @socket = socket
      @socket.on_message do |msg|
        info msg
        write msg
      end
      @socket.read_every 1
    end
 
    def write(msg)
      info "Got a message"
      @socket.write("Recieved #{msg}")
    end
  end
end