diff --git a/find.go b/find.go index 8cbd3d8..fea56ef 100644 --- a/find.go +++ b/find.go @@ -9,7 +9,7 @@ func FindFirst[T any](source <-chan T) *T { func FindFirstAndFlush[T any](source <-chan T) *T { for v := range source { - Flush(source) + go Flush(source) return &v } return nil