executor_unbounded_test.go

package sync

import (
	"context"
	"sync"
	"testing"
)

func Test_unboundedSubcontext(t *testing.T) {
	wg := sync.WaitGroup{}
	wg.Add(1)
	ctx := context.TODO()
	ctx = SetContextExecutor(ctx, "", &unboundedExecutor{})
	ContextExecutor(&ctx, "").Go(func() {
		// context should be able to continue
		ContextExecutor(&ctx, "").Go(func() {
			// context should be able to continue
			ContextExecutor(&ctx, "").Go(func() {
				wg.Done()
			})
		})
	})
	wg.Wait() // only done by sub-executor
}