@Test
public void testSimpleReset() {

  CellChunk cellChunk1 = createCell("row_key1", "family", "qualifier", "value", 1, false);
  CellChunk cellChunk2 = createCell("row_key2", "family", "qualifier", "value", 1, true);
  RowMerger underTest = new RowMerger(observer);
  underTest.onNext(ReadRowsResponse.newBuilder().addChunks(cellChunk1).build());
  underTest.onNext(
      ReadRowsResponse.newBuilder().addChunks(CellChunk.newBuilder().setResetRow(true)).build());
  underTest.onNext(ReadRowsResponse.newBuilder().addChunks(cellChunk2).build());
  verify(observer, times(0)).onNext(eq(toRow(cellChunk1)));
  verify(observer, times(1)).onNext(eq(toRow(cellChunk2)));
}