(b interface{})
| 247 | } |
| 248 | |
| 249 | func (c *rpcCodec) ReadBody(b interface{}) error { |
| 250 | // read body |
| 251 | // read raw data |
| 252 | if v, ok := b.(*raw.Frame); ok { |
| 253 | v.Data = c.buf.rbuf.Bytes() |
| 254 | return nil |
| 255 | } |
| 256 | |
| 257 | if err := c.codec.ReadBody(b); err != nil { |
| 258 | return errors.InternalServerError("go.micro.client.codec", err.Error()) |
| 259 | } |
| 260 | |
| 261 | return nil |
| 262 | } |
| 263 | |
| 264 | func (c *rpcCodec) Close() error { |
| 265 | if err := c.buf.Close(); err != nil { |
nothing calls this directly
no test coverage detected