diff --git a/v4/client/grpc/grpc.go b/v4/client/grpc/grpc.go index 83a3065a..fab5a390 100644 --- a/v4/client/grpc/grpc.go +++ b/v4/client/grpc/grpc.go @@ -557,7 +557,7 @@ func (g *grpcClient) Stream(ctx context.Context, req client.Request, opts ...cli // make the call stream := &grpcStream{} - err = g.stream(ctx, node, req, stream, callOpts) + err = gstream(ctx, node, req, stream, callOpts) g.opts.Selector.Mark(service, node, err) return stream, err