queryLines method

Future<Stream<List>> queryLines(
  1. dynamic fluxQuery, {
  2. Dialect? dialect,
  3. Map<String, Object>? params,
})

Streams the result of fluxQuery using Dialect.

Each line is CSV parsed list of objects.

Implementation

Future<Stream<List<dynamic>>> queryLines(fluxQuery,
    {Dialect? dialect, Map<String, Object>? params}) async {
  var query = fluxQuery is Query ? fluxQuery : Query(query: fluxQuery);

  query.params = params ?? query.params;
  query.dialect = dialect ?? query.dialect;

  var response = await _send('/api/v2/query', {'org': influxDB.org}, query);
  return utf8.decoder
      .bind((response as StreamedResponse).stream)
      .transform(CsvToListConverter());
}