@Test
public void testReadRows() throws Exception {

  ServerStream<Row> stream = mock(ServerStream.class);
  when(dataClientV2.readRows(request)).thenReturn(stream);
  when(stream.iterator()).thenReturn(rows.iterator());
  ResultScanner<Row> results = dataGCJClient.readRows(request);
  assertEquals(rows.get(0), results.next());
  assertEquals(rows.get(1), results.next());
  verify(dataClientV2).readRows(request);
  verify(stream).iterator();
}