Method executeStream

repos/effect/packages/sql/pg/src/PgClient.ts:724–748

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

            )
          } else {
            resume(Effect.succeed(result.rows))
          }
        }
      )
    })
  }
  executeValuesUnprepared(sql: string, params: ReadonlyArray<unknown>) {
    return this.executeValues(sql, params)
  }
  executeUnprepared(
    sql: string,
    params: ReadonlyArray<unknown>,
    transformRows: (<A extends object>(row: ReadonlyArray<A>) => ReadonlyArray<A>) | undefined
  ) {
    return this.execute(sql, params, transformRows)
  }
  executeStream(
    sql: string,
    params: ReadonlyArray<unknown>,
    transformRows: (<A extends object>(row: ReadonlyArray<A>) => ReadonlyArray<A>) | undefined
  ) {
    // oxlint-disable-next-line @typescript-eslint/no-this-alias
    const self = this
    return Stream.fromChannel(Channel.fromTransform(Effect.fnUntraced(function*(_, scope) {
      const client = yield* Scope.provide(self.reserve, scope)
      yield* Scope.addFinalizer(scope, Effect.promise(() => cursor.close()))
      const cursor = client.query(new Cursor(sql, params as any))
      // @effect-diagnostics-next-line returnEffectInGen:off