public void testFileChangesDuringRead() throws IOException {
  File f1 = new File(tmpDir.getAbsolutePath() + "/file1");

  Files.write("file1line1\nfile1line2\n", f1, Charsets.UTF_8);

  ReliableSpoolingFileEventReader parser1 = getParser();

  List<String> out = Lists.newArrayList();
  out.addAll(bodiesAsStrings(parser1.readEvents(2)));
  parser1.commit();

  assertEquals(2, out.size());
  assertTrue(out.contains("file1line1"));
  assertTrue(out.contains("file1line2"));

  Files.append("file1line3\n", f1, Charsets.UTF_8);

  out.add(bodyAsString(parser1.readEvent()));
  parser1.commit();
  out.add(bodyAsString(parser1.readEvent()));
  parser1.commit();
}

        
main