Contents

module EventMachine
  
  class Connection

    attr_writer :netty_handler

    def self.new(*args)
      allocate.instance_eval do
        initialize(*args)
        self
      end
    end

    def initialize(*args); end

    def send_data(data)
      @netty_handler.write(data)
    end

    def broadcast(data)
      @netty_handler.write(data, true)
    end

    def send_file_data(path)
      @netty_handler.send_file(path)
    end

    def post_init; end

    def unbind; end

    def start_tls(args={}); end

    def receive_data(data)
      puts 'Incoming data...'
    end

    def close_connection(after_writing=false)
      @netty_handler.close
    end

    def close_connection_after_writing
      close_connection(true)
    end

    def get_peername
      @netty_handler.peername
    end

    def comm_inactivity_timeout=(seconds)
      @netty_handler.set_read_timeout(seconds)
    end

  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
foxbat-0.2.6	lib/em/connection.rb
foxbat-0.2.5	lib/em/connection.rb