Function stream

packages/platform/browser/src/IndexedDbQueryBuilder.ts:1769–1793

(this: IndexedDbQuery.Select<any, never>, options?: {
    readonly chunkSize?: number | undefined
  })

    })
  },
  stream(this: IndexedDbQuery.Select<any, never>, options?: {
    readonly chunkSize?: number | undefined
  }) {
    const limit = this.limitValue
    const chunkSize = Math.min(options?.chunkSize ?? 100, limit ?? Number.MAX_SAFE_INTEGER)
    const initialOffset = this.offsetValue ?? 0
    return Stream.suspend(() => {
      let total = 0
      const initial = this.limit(chunkSize)
      return Stream.paginate(initial, (select) =>
        Effect.map(
          applySelect(select as any),
          (data) => {
            total += data.length
            const reachedLimit = limit && total >= limit
            const isPartial = data.length < chunkSize
            const next = makeSelect({
              ...select,
              offsetValue: initialOffset + total
            })
            return [data, isPartial || reachedLimit ? Option.none() : Option.some(next)] as const
          }
        ))
    })
  },
  reactive(
    this: IndexedDbQuery.Select<any, never>,
    keys?: ReadonlyArray<unknown> | Record.ReadonlyRecord<string, ReadonlyArray<unknown>> | undefined