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

    // When
    final Row receivedRow = queryResult.poll();

    // Then
    assertThat(receivedRow, is(row));
  }