| 752 | * @since 4.0.0 |
| 753 | */ |
| 754 | export const fromIteratorArray = <A, L>( |
| 755 | iterator: LazyArg<Iterator<A, L>>, |
| 756 | chunkSize = DefaultChunkSize |
| 757 | ): Channel<Arr.NonEmptyReadonlyArray<A>, never, L> => |
| 758 | fromPull( |
| 759 | Effect.sync(() => { |
| 760 | const iter = iterator() |
| 761 | let done = Option.none<L>() |
| 762 | return Effect.suspend(() => { |
| 763 | if (done._tag === "Some") return Cause.done(done.value) |
| 764 | const buffer: Array<A> = [] |
| 765 | while (buffer.length < chunkSize) { |
| 766 | const state = iter.next() |
| 767 | if (state.done) { |
| 768 | if (buffer.length === 0) { |
| 769 | return Cause.done(state.value) |
| 770 | } |
| 771 | done = Option.some(state.value) |
| 772 | break |
| 773 | } |
| 774 | buffer.push(state.value) |
| 775 | } |
| 776 | return Effect.succeed(buffer as any as Arr.NonEmptyReadonlyArray<A>) |
| 777 | }) |
| 778 | }) |
| 779 | ) |
| 780 | |
| 781 | /** |
| 782 | * Creates a `Channel` that emits all elements from an iterable. |