@Test
public void testMultipleResponses() throws UnsupportedEncodingException {

  RetryingReadRowsOperation underTest = createOperation();
  start(underTest);
  ByteString key1 = ByteString.copyFrom("SomeKey1", "UTF-8");
  ByteString key2 = ByteString.copyFrom("SomeKey2", "UTF-8");
  underTest.onMessage(buildResponse(key1));
  underTest.onMessage(buildResponse(key2));
  verify(mockFlatRowObserver, times(2)).onNext(any(FlatRow.class));
  checkRetryRequest(underTest, key2, 8);
  verify(mockClientCall, times(3)).request(eq(1));
  finishOK(underTest, 0);
}