chore: simplify queryPoints

InfluxCommunity · Sep 19, 2023 · 095a51c · 095a51c
1 parent 29ed883
commit 095a51c
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 6 deletions.
diff --git a/packages/client/src/InfluxDBClient.ts b/packages/client/src/InfluxDBClient.ts
@@ -98,22 +98,18 @@ export default class InfluxDBClient {
    * @param queryType - The type of query (default: 'sql').
    * @returns An async generator that yields PointValues object.
    */
-  async *queryPoints(
+  queryPoints(
     query: string,
     database?: string,
     queryType: QueryType = 'sql'
   ): AsyncGenerator<PointValues, void, void> {
-    const points = this._queryApi.queryPoints(
+    return this._queryApi.queryPoints(
       query,
       database ??
         this._options.database ??
         throwReturn(new Error(argumentErrorMessage)),
       queryType
     )
-
-    for await (const point of points) {
-      yield point
-    }
   }
 
   /**

diff --git a/packages/client/test/unit/util/point.test.ts b/packages/client/test/unit/util/point.test.ts
@@ -4,6 +4,7 @@ import {Point, PointValues, convertTime} from '../../../src'
 describe('point', () => {
   it('creates point with various fields', () => {
     const point = Point.measurement('blah')
+      .setMeasurement('')
       .setBooleanField('truthy', true)
       .setBooleanField('falsy', false)
       .setIntegerField('intFromString', '20')