From 5657fd07d27688d214fc2d446bf99df10395e286 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 --- grpc.go | 1 + 1 file changed, 1 insertion(+) diff --git a/grpc.go b/grpc.go index 542c917..e3ada84 100644 --- a/grpc.go +++ b/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(), }