flush_sync

in lib/kinesis_producer/library.rb [101:107]


    def flush_sync
      while @futures.size > 0
        flush()
        sleep 0.5
      end
    end