Function TestPutToOutput_Normal

core/pool/pool_test.go:461–475

--------------------------------------------------------------------------- putToOutput ---------------------------------------------------------------------------

(t *testing.T)

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

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

	pool.putToOutput(newTestBaseline())

	select {
	case <-pool.OutputCh:
	case <-time.After(time.Second):
		t.Fatal("putToOutput: receive timed out")
	}
	pool.Outwg.Done()
	pool.Outwg.Wait()
}

func TestPutToOutputSnapshotsBaseline(t *testing.T) {
	ctx, cancel := context.WithCancel(context.Background())