()
| 160 | |
| 161 | /** @internal */ |
| 162 | export const collectAllToSet = <In>(): Sink.Sink<HashSet.HashSet<In>, In> => |
| 163 | foldLeftChunks<HashSet.HashSet<In>, In>( |
| 164 | HashSet.empty(), |
| 165 | (acc, chunk) => pipe(chunk, Chunk.reduce(acc, (acc, input) => pipe(acc, HashSet.add(input)))) |
| 166 | ) |
| 167 | |
| 168 | /** @internal */ |
| 169 | export const collectAllToSetN = <In>(n: number): Sink.Sink<HashSet.HashSet<In>, In, In> => |
nothing calls this directly
no test coverage detected