Method executeStream

packages/sql/pglite/src/PgliteClient.ts:330–339

(
    sql: string,
    params: ReadonlyArray<unknown>,
    transformRows: (<A extends object>(row: ReadonlyArray<A>) => ReadonlyArray<A>) | undefined
  )

      : this.run("executeUnprepared", sql, params)
  }
  executeStream(
    sql: string,
    params: ReadonlyArray<unknown>,
    transformRows: (<A extends object>(row: ReadonlyArray<A>) => ReadonlyArray<A>) | undefined
  ) {
    const eff = transformRows
      ? Effect.map(this.run("executeStream", sql, params), transformRows)
      : this.run("executeStream", sql, params)
    return Stream.fromArrayEffect(eff)
  }
}

/**