Contents

class Fwd::Input < EM::Connection
  extend Forwardable
  def_delegators :core, :logger

  attr_reader :core, :buffer

  # @param [Fwd] core
  # @param [Hash] opts additional opts
  def initialize(core)
    @core = core
  end

  def post_init
    @buffer = Fwd::Buffer.new(core)
  end

  # When receiving data, concat it to the buffer
  def receive_data(data)
    buffer.concat(data)
  end

end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
fwd-0.3.2	lib/fwd/input.rb
fwd-0.3.1	lib/fwd/input.rb
fwd-0.3.0	lib/fwd/input.rb