query method

Future<Stream<FluxRecord>> query(
  1. dynamic fluxQuery, {
  2. Map<String, Object>? params,
})

Streams the result of query into Stream<FluxRecord>

Implementation

Future<Stream<FluxRecord>> query(fluxQuery,
    {Map<String, Object>? params}) async {
  var query = fluxQuery is Query ? fluxQuery : Query(query: fluxQuery);

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

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