diff --git a/flat.go b/flat.go index a070da9..9d112f8 100644 --- a/flat.go +++ b/flat.go @@ -15,7 +15,7 @@ func FlatSlice[T any](source <-chan []T) <-chan T { return out } -func FlatChan[T any](source <-chan chan T) <-chan T { +func FlatChan[T any](source <-chan <-chan T) <-chan T { out := make(chan T, cap(source)) go func() {