streamQueryColumnar method

Stream<Result<TypedColumnarResult>> streamQueryColumnar(
  1. String connectionId,
  2. String sql
)

Implementation

Stream<Result<TypedColumnarResult>> streamQueryColumnar(
  String connectionId,
  String sql,
) async* {
  await for (final chunk
      in _repository.streamQueryColumnar(connectionId, sql)) {
    yield chunk;
  }
}