ing
This commit is contained in:
parent
258c206988
commit
b36507490a
|
@ -70,6 +70,7 @@ func newClientResponseCodec(r io.Reader, codec codec.Codec) (protocol.ClientResp
|
||||||
if nil == r {
|
if nil == r {
|
||||||
return nil, io.EOF
|
return nil, io.EOF
|
||||||
}
|
}
|
||||||
|
decoder.UseNumber()
|
||||||
|
|
||||||
res := &clientResponse{}
|
res := &clientResponse{}
|
||||||
err := decoder.Decode(res)
|
err := decoder.Decode(res)
|
||||||
|
|
|
@ -42,6 +42,7 @@ func newServerRequestCodec(r io.Reader, codec codec.Codec) (protocol.ServerReque
|
||||||
if nil == r {
|
if nil == r {
|
||||||
return nil, io.EOF
|
return nil, io.EOF
|
||||||
}
|
}
|
||||||
|
decoder.UseNumber()
|
||||||
|
|
||||||
req := &serverRequest{}
|
req := &serverRequest{}
|
||||||
err := decoder.Decode(req)
|
err := decoder.Decode(req)
|
||||||
|
|
Loading…
Reference in New Issue
Block a user