( self: Sink.Sink<A, In, L, E, R> )
| 112 | |
| 113 | /** @internal */ |
| 114 | export const collectAllFrom = <A, In, L extends In, E, R>( |
| 115 | self: Sink.Sink<A, In, L, E, R> |
| 116 | ): Sink.Sink<Chunk.Chunk<A>, In, L, E, R> => |
| 117 | collectAllWhileWith(self, { |
| 118 | initial: Chunk.empty<A>(), |
| 119 | while: constTrue, |
| 120 | body: (chunk, a) => pipe(chunk, Chunk.append(a)) |
| 121 | }) |
| 122 | |
| 123 | /** @internal */ |
| 124 | export const collectAllToMap = <In, K>( |