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(),
 	}