def testUtf8CsvReader(self):
    self._SetupTestFlags()
    self.mox.StubOutWithMock(load_lib.csv, 'reader')
    input_path = '/path/to/file'
    csv_reader = [['line0'], ['line1']]

    expect_kwargs = {'dialect': 'excel', 'foo': 'bar'}
    load_lib.csv.reader(input_path, **expect_kwargs).AndReturn(csv_reader)
    i = 0

    self.mox.ReplayAll()
    reader = load_lib._Utf8CsvReader(input_path, foo='bar')
    for row in reader:
      self.assertTrue(i <= len(csv_reader))
      self.assertEqual(row, csv_reader[i])
      i += 1
    self.mox.VerifyAll()
Async version of flush_all().
dataset/ETHPy150Open google/encrypted-bigquery-client/src/load_lib_test.py/LoadLibraryTest.testUtf8CsvReader--crossover with--dataset/ETHPy150Open AppScale/appscale/AppServer/google/appengine/api/memcache/__init__.py/Client.flush_all_async