set dial timeout in stream

2020-02-13 18:51:32 +00:00 · 2020-02-13 18:51:32 +00:00 · 5657fd07d2
commit 5657fd07d2
parent 978659a441
1 changed files with 1 additions and 0 deletions
--- 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(),
 	}