Function New

promise/promise.go:30–45

New create a new promise instance.

(runnable func(resolve func(T), reject func(error)))

// New create a new promise instance.
func New[T any](runnable func(resolve func(T), reject func(error))) *Promise[T] {
	if runnable == nil {
		panic("runnable function should not be nil")
	}

	p := &Promise[T]{
		runnable: runnable,
		pending:  true,
		mu:       &sync.Mutex{},
		wg:       &sync.WaitGroup{},
	}

	defer p.run()

	return p
}

func (p *Promise[T]) run() {
	p.wg.Add(1)