From 067cf68d2312adb2a154c756c8f6990a4f915339 Mon Sep 17 00:00:00 2001 From: Vasiliy Tolstov Date: Thu, 26 Nov 2020 01:45:58 +0300 Subject: [PATCH] fix stream wrapping Signed-off-by: Vasiliy Tolstov --- grpc.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/grpc.go b/grpc.go index e9d8041..cb943b3 100644 --- a/grpc.go +++ b/grpc.go @@ -548,7 +548,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) // record the result of the call to inform future routing decisions if verr := g.opts.Selector.Record(node, err); verr != nil {