Method: MoSQL::Streamer#initialize

Defined in:
lib/mosql/streamer.rb

#initialize(opts) ⇒ Streamer

Returns a new instance of Streamer.



11
12
13
14
15
16
17
18
19
20
 
# File 'lib/mosql/streamer.rb', line 11

def initialize(opts)
  NEW_KEYS.each do |parm|
    unless opts.key?(parm)
      raise ArgumentError.new("Required argument `#{parm}' not provided to #{self.class.name}#new.")
    end
    instance_variable_set(:"@#{parm.to_s}", opts[parm])
  end

  @done    = false
end