Function TestHandlerDone_ProcessesAllBeforeExit

core/pool/pool_test.go:638–661

(t *testing.T)

}

func TestHandlerDone_ProcessesAllBeforeExit(t *testing.T) {
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()
	pool := newTestBasePool(ctx, cancel)

	var count int
	go func() {
		defer close(pool.handlerDone)
		for range pool.processCh {
			count++
		}
	}()

	const N = 20
	for i := 0; i < N; i++ {
		pool.processCh <- newTestBaseline()
	}
	close(pool.processCh)
	<-pool.handlerDone

	if count != N {
		t.Fatalf("handler processed %d items, want %d", count, N)
	}
}

// ---------------------------------------------------------------------------
// Full shutdown sequence (integration-level)