in lib/kinesis_producer/daemon.rb [128:136]
def start_loop_for(method)
@executor.post do
while @shutdown.false?
send(method)
@meters[method].mark if debug? and @meters.include?(method)
end
end
end