Function newTestBasePool

core/pool/pool_test.go:24–40

--------------------------------------------------------------------------- helpers ---------------------------------------------------------------------------

(ctx context.Context, cancel context.CancelFunc)

// ---------------------------------------------------------------------------

func newTestBasePool(ctx context.Context, cancel context.CancelFunc) *BasePool {
	return &BasePool{
		Config: &Config{
			Thread:   4,
			OutputCh: make(chan *baseline.Baseline, 100),
			FuzzyCh:  make(chan *baseline.Baseline, 100),
			Outwg:    &sync.WaitGroup{},
		},
		ctx:         ctx,
		Cancel:      cancel,
		additionCh:  make(chan *Unit, 40), // Thread*10
		closeCh:     make(chan struct{}),
		processCh:   make(chan *baseline.Baseline, 8), // Thread*2
		wg:          &sync.WaitGroup{},
		handlerDone: make(chan struct{}),
	}
}

func newTestBaseline() *baseline.Baseline {
	return &baseline.Baseline{