Function newWSRequestBody

proxy/proxy_test.go:744–753

(data []byte)

}

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

func newTCPRequestBody(data []byte) *requestBody {
	pr, pw := io.Pipe()