diff --git a/client/rpc_stream.go b/client/rpc_stream.go index 1fb76506..e5a27033 100644 --- a/client/rpc_stream.go +++ b/client/rpc_stream.go @@ -44,7 +44,7 @@ func (r *rpcStream) Send(msg interface{}) error { } seq := r.seq - + req := request{ Service: r.request.Service(), Seq: seq,