We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5c30926 commit b514a6bCopy full SHA for b514a6b
src/client.ts
@@ -3,7 +3,6 @@ import { FlightSqlClient } from "./flightsql";
3
import { arrow as fsql } from "./generated/flightsql";
4
import { RecordBatch } from "apache-arrow";
5
import { pipe, toArray } from "iter-ops";
6
-import { firstValueFrom } from "./async_util";
7
8
/**
9
* Options for creating a new client.
@@ -78,7 +77,7 @@ export class QueryResult {
78
77
* @returns an array of Arrow record batches
79
*/
80
public async collectToArrow(): Promise<RecordBatch[]> {
81
- const batches = await firstValueFrom(pipe(this.raw, toArray()));
+ const batches = await pipe(this.raw, toArray()).first;
82
return batches ?? [];
83
}
84
0 commit comments