fixed bug in FlatChan

2022-08-21 21:22:16 +02:00 · 2022-08-21 21:22:16 +02:00 · a564503c8d
commit a564503c8d
parent 4e422b4243
1 changed files with 1 additions and 1 deletions
--- 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() {