remove clientCodec

client/rpc_codec.go

@@ -45,12 +45,6 @@ type readWriteCloser struct {
 	rbuf *bytes.Buffer
 }
 
-type clientCodec interface {
-	Write(*request, interface{}) error
-	Read(*response, interface{}) error
-	Close() error
-}
-
 type request struct {
 	Service       string
 	ServiceMethod string   // format: "Service.Method"

client/rpc_stream.go

@@ -13,7 +13,7 @@ type rpcStream struct {
 	closed  chan bool
 	err     error
 	request Request
-	codec   clientCodec
+	codec   *rpcCodec
 	context context.Context
 }