@Override
  public Row poll() {
    return poll(Duration.ZERO);
  }
@Test
  public void shouldNotPollIfFailed() throws Exception {
    // Given
    handleQueryResultError();

    // When
    final Exception e = assertThrows(IllegalStateException.class, () -> queryResult.poll());

    // Then
    assertThat(e.getMessage(), containsString("Cannot poll on StreamedQueryResult that has failed"));
  }