|
|
@@ -135,7 +135,7 @@ func transferRequest(timer signal.ActivityTimer, session *encoding.ServerSession
|
|
|
return nil
|
|
|
}
|
|
|
|
|
|
-func transferResponse(timer signal.ActivityTimer, session *encoding.ServerSession, request *protocol.RequestHeader, response *protocol.ResponseHeader, input ray.InputStream, output io.Writer) error {
|
|
|
+func transferResponse(timer signal.ActivityTimer, session *encoding.ServerSession, request *protocol.RequestHeader, response *protocol.ResponseHeader, input buf.Reader, output io.Writer) error {
|
|
|
session.EncodeResponseHeader(response, output)
|
|
|
|
|
|
bodyWriter := session.EncodeResponseBody(request, output)
|