diff --git a/api/rpc/client/init.go b/api/rpc/client/init.go
index 706e6a9..9d8dbe1 100644
--- a/api/rpc/client/init.go
+++ b/api/rpc/client/init.go
@@ -50,7 +50,7 @@ func (c *Client) Init(info common.CallMethodInfo, opts ...CallOption) (MessageRe
 		return nil, err
 	}
 
-	ctx, cancel := context.WithCancel(prm.ctx)
+	ctx, cancel := context.WithTimeout(prm.ctx, c.dialTimeout)
 	stream, err := c.conn.NewStream(ctx, &grpc.StreamDesc{
 		StreamName:    info.Name,
 		ServerStreams: info.ServerStream(),