unistack-org/micro
4
0
Fork 3
Code Issues 20 Pull Requests 1 Actions Packages Projects Releases 281 Wiki Activity

remove Plus

Browse Source
This commit is contained in:
Asim Aslam 2018-12-31 20:51:22 +00:00
parent 386ced576a
commit b3b4bc6059
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
client/rpc_client.go
View File

@ -96,7 +96,7 @@ func (r *rpcClient) call(ctx context.Context, address string, req Request, resp
context: ctx, context: ctx,
request: req, request: req,
closed: make(chan bool), closed: make(chan bool),
codec: newRpcPlusCodec(msg, c, cf), codec: newRpcCodec(msg, c, cf),
seq: seq, seq: seq,
} }
defer stream.Close() defer stream.Close()
@ -177,7 +177,7 @@ func (r *rpcClient) stream(ctx context.Context, address string, req Request, opt
context: ctx, context: ctx,
request: req, request: req,
closed: make(chan bool), closed: make(chan bool),
codec: newRpcPlusCodec(msg, c, cf), codec: newRpcCodec(msg, c, cf),
} }
ch := make(chan error, 1) ch := make(chan error, 1)

2
client/rpc_codec.go
View File

@ -87,7 +87,7 @@ func (rwc *readWriteCloser) Close() error {
return nil 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{ rwc := &readWriteCloser{
wbuf: bytes.NewBuffer(nil), wbuf: bytes.NewBuffer(nil),
rbuf: bytes.NewBuffer(nil), rbuf: bytes.NewBuffer(nil),