From d9b3b1758235fb0ed58743880f7ba1162a4fd126 Mon Sep 17 00:00:00 2001 From: Asim Aslam Date: Thu, 13 Feb 2020 18:51:32 +0000 Subject: [PATCH] set dial timeout in stream --- client/grpc/grpc.go | 1 + 1 file changed, 1 insertion(+) diff --git a/client/grpc/grpc.go b/client/grpc/grpc.go index 542c9173..e3ada840 100644 --- a/client/grpc/grpc.go +++ b/client/grpc/grpc.go @@ -189,6 +189,7 @@ func (g *grpcClient) stream(ctx context.Context, node *registry.Node, req client grpcDialOptions := []grpc.DialOption{ grpc.WithDefaultCallOptions(grpc.ForceCodec(wc)), + grpc.WithTimeout(opts.DialTimeout), g.secure(), }