Function executeStream

packages/sql-sqlite-do/src/SqliteClient.ts:140–153

(sql, params, transformRows)

            : runStatement(sql, params)
        },
        executeStream(sql, params, transformRows) {
          return Stream.suspend(() => {
            const iterator = runIterator(sql, params)
            return Stream.fromIteratorSucceed(iterator, 16)
          }).pipe(
            transformRows
              ? Stream.mapChunks((chunk) =>
                Chunk.unsafeFromArray(
                  transformRows(Chunk.toReadonlyArray(chunk))
                )
              )
              : identity
          )
        }
      })
    })