Function DrainChannelSafe

pkg/util/utilfn/utilfn.go:1084–1101

DrainChannelSafe will drain a channel until it is empty or until a timeout is reached.

(ch <-chan T, debugName string)

// DrainChannelSafe will drain a channel until it is empty or until a timeout is reached.
func DrainChannelSafe[T any](ch <-chan T, debugName string) {
	drainTimeoutCtx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
	go func() {
		defer cancel()
	outer:
		for {
			select {
			case <-drainTimeoutCtx.Done():
				log.Printf("[error] timeout draining channel: %s\n", debugName)
				break outer
			case _, ok := <-ch:
				if !ok {
					return
				}
			}
		}
	}()
}


func IsBinaryContent(data []byte) bool {