diff --git a/client/rpc_client.go b/client/rpc_client.go
index 7b44d7c5..2b84d5dd 100644
--- a/client/rpc_client.go
+++ b/client/rpc_client.go
@@ -96,7 +96,7 @@ func (r *rpcClient) call(ctx context.Context, address string, req Request, resp
 		context: ctx,
 		request: req,
 		closed:  make(chan bool),
-		codec:   newRpcPlusCodec(msg, c, cf),
+		codec:   newRpcCodec(msg, c, cf),
 		seq:     seq,
 	}
 	defer stream.Close()
@@ -177,7 +177,7 @@ func (r *rpcClient) stream(ctx context.Context, address string, req Request, opt
 		context: ctx,
 		request: req,
 		closed:  make(chan bool),
-		codec:   newRpcPlusCodec(msg, c, cf),
+		codec:   newRpcCodec(msg, c, cf),
 	}
 
 	ch := make(chan error, 1)
diff --git a/client/rpc_codec.go b/client/rpc_codec.go
index 01fe9208..95ff1da1 100644
--- a/client/rpc_codec.go
+++ b/client/rpc_codec.go
@@ -87,7 +87,7 @@ func (rwc *readWriteCloser) Close() error {
 	return nil
 }
 
-func newRpcPlusCodec(req *transport.Message, client transport.Client, c codec.NewCodec) *rpcCodec {
+func newRpcCodec(req *transport.Message, client transport.Client, c codec.NewCodec) *rpcCodec {
 	rwc := &readWriteCloser{
 		wbuf: bytes.NewBuffer(nil),
 		rbuf: bytes.NewBuffer(nil),