parallel: fix PartitionBy

Should fix the tests.
This commit is contained in:
francisco souza
2022-03-05 17:49:15 -05:00
parent 38cc7acd4a
commit a43b3a8e79

View File

@@ -116,6 +116,7 @@ func PartitionBy[T any, K comparable](collection []T, iteratee func (x T) K) [][
for _, item := range collection {
go func(_item T) {
defer wg.Done()
key := iteratee(_item)
mu.Lock()