func ToMap[T any, K comparable, V any](s Stream[T], mapper func(item T) (K, V), mergeFunc func(existing, new V) V) map[K]V {
	m := make(map[K]V, len(s.source))
	for _, v := range s.source {
		key, value := mapper(v)
		if existing, ok := m[key]; ok {
			if mergeFunc != nil {
				m[key] = mergeFunc(existing, value)
				continue
			}
		}
		m[key] = value
	}
	return m
} 

func ToMap[T any, K comparable, V any](s Stream[T], mapper func(item T) (K, V)) map[K]V {
	return ToMapWithMerge(s, mapper, nil)
}

func ToMapWithMerge[T any, K comparable, V any](s Stream[T], mapper func(item T) (K, V), mergeFunc func(existing, new V) V) map[K]V