@Test
public void testSingleResponse() throws UnsupportedEncodingException {

  RetryingReadRowsOperation underTest = createOperation();
  start(underTest);
  ByteString key = ByteString.copyFrom("SomeKey", "UTF-8");
  ReadRowsResponse response = buildResponse(key);
  underTest.onMessage(response);
  verify(mockFlatRowObserver, times(1)).onNext(any(FlatRow.class));
  checkRetryRequest(underTest, key, 9);
  verify(mockClientCall, times(2)).request(eq(1));
  verify(mockResponseObserver, times(1)).onNext(same(response));
  finishOK(underTest, 0);
}