diff --git a/client/rpc_client.go b/client/rpc_client.go index 681e6298..d46fdcd7 100644 --- a/client/rpc_client.go +++ b/client/rpc_client.go @@ -89,7 +89,7 @@ func (r *rpcClient) call(ctx context.Context, address string, req Request, resp r.pool.release(address, c, grr) }() - seq := r.seq + seq := atomic.LoadUint64(&r.seq) atomic.AddUint64(&r.seq, 1) stream := &rpcStream{