()
| 262 | } |
| 263 | |
| 264 | func (c *rpcCodec) Close() error { |
| 265 | if err := c.buf.Close(); err != nil { |
| 266 | return err |
| 267 | } |
| 268 | |
| 269 | if err := c.codec.Close(); err != nil { |
| 270 | return err |
| 271 | } |
| 272 | |
| 273 | if err := c.client.Close(); err != nil { |
| 274 | return errors.InternalServerError("go.micro.client.transport", err.Error()) |
| 275 | } |
| 276 | |
| 277 | return nil |
| 278 | } |
| 279 | |
| 280 | func (c *rpcCodec) String() string { |
| 281 | return "rpc" |
nothing calls this directly
no test coverage detected