class StreamedQueryResultImpl extends BufferedPublisher<Row> implements StreamedQueryResult {

  @Override
  public Row poll() {
    return poll(Duration.ZERO);
  }

    StreamedQueryResultImpl(
      final Context context,
      final String queryId,
      final List<String> columnNames,
      final List<ColumnType> columnTypes
  );

}