Function newTestPair

x/acpio/acpio_test.go:56–82

newTestPair creates an ACPAgentIO connected to a testAgent via pipes.

(t *testing.T, agent *testAgent)

// newTestPair creates an ACPAgentIO connected to a testAgent via pipes.
func newTestPair(t *testing.T, agent *testAgent) *acpio.ACPAgentIO {
	t.Helper()

	// Two pipe pairs: client writes → agent reads, agent writes → client reads.
	clientToAgentR, clientToAgentW := io.Pipe()
	agentToClientR, agentToClientW := io.Pipe()

	// Client side: peerInput=clientToAgentW (writes to agent), peerOutput=agentToClientR (reads from agent)
	// Agent side:  peerInput=agentToClientW (writes to client), peerOutput=clientToAgentR (reads from client)
	asc := acp.NewAgentSideConnection(agent, agentToClientW, clientToAgentR)
	agent.SetAgentConnection(asc)

	agentIO, err := acpio.NewWithPipes(
		context.Background(),
		clientToAgentW, agentToClientR,
		nil,
		func() (string, error) { return os.TempDir(), nil },
	)
	require.NoError(t, err)

	t.Cleanup(func() {
		_ = clientToAgentW.Close()
		_ = agentToClientW.Close()
	})

	return agentIO
}

// chunkCollector collects chunks from SetOnChunk in a thread-safe way
// and provides a method to wait for a specific number of chunks.