@Test
public void testLargestQueuedTimestampWithRead() {

  writeTestData();
  assertThat(sampleQueue.getLargestQueuedTimestampUs()).isEqualTo(LAST_SAMPLE_TIMESTAMP);
  assertReadTestData();
  // Reading everything should not reduce the largest timestamp.
  assertThat(sampleQueue.getLargestQueuedTimestampUs()).isEqualTo(LAST_SAMPLE_TIMESTAMP);
}