Function Go

internal/xsync/go.go:10–26

Go allows running a function in another goroutine and waiting for its error.

(fn func() error)

// Go allows running a function in another goroutine
// and waiting for its error.
func Go(fn func() error) <-chan error {
	errs := make(chan error, 1)
	go func() {
		defer func() {
			r := recover()
			if r != nil {
				select {
				case errs <- fmt.Errorf("panic in go fn: %v, %s", r, debug.Stack()):
				default:
				}
			}
		}()
		errs <- fn()
	}()

	return errs
}