together.go

func pipelining(outgoing *bufio.Writer, incoming *bufio.Reader) chan request {
	requests := make(chan request, 512)
	waiting := make(chan request, 512)
	go func() { writing(outgoing, requests, waiting) }()
	go func() { reading(incoming, waiting) }()
	return requests
}

func makeRequest(requests chan request, data []byte) response {
	respCh := make(chan response, 1)
	requests <- request{body: data, caller: respCh}
	return <-respCh
}