Function executeStream

repos/effect/packages/sql/sqlite-wasm/src/SqliteClient.ts:217–241

(sql, params, transformRows)

        executeUnprepared(sql, params, transformRows) {
          return this.execute(sql, params, transformRows)
        },
        executeStream(sql, params, transformRows) {
          function* stream() {
            for (const stmt of sqlite3.statements(db, sql)) {
              let columns: Array<string> | undefined
              sqlite3.bind_collection(stmt, params as any)
              while (sqlite3.step(stmt) === WaSqlite.SQLITE_ROW) {
                columns = columns ?? sqlite3.column_names(stmt)
                const row = sqlite3.row(stmt)
                const obj: Record<string, any> = {}
                for (let i = 0; i < columns.length; i++) {
                  Rec.assignProperty(obj, columns[i], row[i])
                }
                yield obj
              }
            }
          }
          return Stream.suspend(() => Stream.fromIteratorSucceed(stream()[Symbol.iterator]())).pipe(
            transformRows
              ? Stream.mapArray((chunk) => transformRows(chunk) as any)
              : identity,
            Stream.mapError((cause) =>
              new SqlError({ reason: classifyError(cause, "Failed to execute statement", "stream") })
            )
          )
        },
        export: Effect.try({
          try: () => sqlite3.serialize(db, "main"),