Function newTCPRequestBody

proxy/proxy_test.go:755–764

(data []byte)

}

func newTCPRequestBody(data []byte) *requestBody {
	pr, pw := io.Pipe()
	go func() {
		_, _ = pw.Write(data)
	}()
	return &requestBody{
		pr: pr,
		pw: pw,
	}
}

func (r *requestBody) Read(p []byte) (n int, err error) {
	return r.pr.Read(p)