channel/find.go

package channel

func FindFirst[T any](source <-chan T) *T {
	for v := range source {
		return &v
	}
	return nil
}

func FindFirstAndFlush[T any](source <-chan T) *T {
	for v := range source {
		go Flush(source)
		return &v
	}
	return nil
}

func FindLast[T any](source <-chan T) *T {
	var last *T = new(T)
	found := false

	for v := range source {
		*last = v
		found = true
	}

	if !found {
		return nil
	}

	return last
}