Method ReadHeader

client/rpc_codec.go:221–247

(msg *codec.Message, r codec.MessageType)

}

func (c *rpcCodec) ReadHeader(msg *codec.Message, r codec.MessageType) error {
	var tm transport.Message

	// read message from transport
	if err := c.client.Recv(&tm); err != nil {
		return errors.InternalServerError("go.micro.client.transport", err.Error())
	}

	c.buf.rbuf.Reset()
	c.buf.rbuf.Write(tm.Body)

	// set headers from transport
	msg.Header = tm.Header

	// read header
	err := c.codec.ReadHeader(msg, r)

	// get headers
	getHeaders(msg)

	// return header error
	if err != nil {
		return errors.InternalServerError("go.micro.client.codec", err.Error())
	}

	return nil
}

func (c *rpcCodec) ReadBody(b interface{}) error {
	// read body