in lib/kinesis_producer/library.rb [101:107]
def flush_sync while @futures.size > 0 flush() sleep 0.5 end end