From b3b4bc6059f0d9f3d30b82c0396abdf6588dcdf8 Mon Sep 17 00:00:00 2001 From: Asim Aslam Date: Mon, 31 Dec 2018 20:51:22 +0000 Subject: [PATCH] remove Plus --- client/rpc_client.go | 4 ++-- client/rpc_codec.go | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) 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),