Lines Matching defs:rpcCodec

39 type rpcCodec struct {  struct
40 	rwc io.ReadWriteCloser
41 	dec *Decoder
42 	enc *Encoder
43 	bw  *bufio.Writer
44 	br  *bufio.Reader
45 	mu  sync.Mutex
46 	h   Handle
48 	cls   bool
49 	clsmu sync.RWMutex
65 func (c *rpcCodec) BufferedReader() *bufio.Reader {
69 func (c *rpcCodec) BufferedWriter() *bufio.Writer {
73 func (c *rpcCodec) write(obj1, obj2 interface{}, writeObj2, doFlush bool) (err error) {
98 func (c *rpcCodec) read(obj interface{}) (err error) {
110 func (c *rpcCodec) isClosed() bool {
117 func (c *rpcCodec) Close() error {
127 func (c *rpcCodec) ReadResponseBody(body interface{}) error {
134 	rpcCodec  anonMember