| 35 | ) |
| 36 | |
| 37 | type rpcCodec struct { |
| 38 | client transport.Client |
| 39 | codec codec.Codec |
| 40 | |
| 41 | req *transport.Message |
| 42 | buf *readWriteCloser |
| 43 | |
| 44 | // signify if its a stream |
| 45 | stream string |
| 46 | } |
| 47 | |
| 48 | type readWriteCloser struct { |
| 49 | wbuf *bytes.Buffer |
nothing calls this directly
no outgoing calls
no test coverage detected