[#XX] rpc: Use connect

Signed-off-by: Airat Arifullin <a.arifullin@yadro.com>
2024-12-05 13:06:53 +03:00
2 changed files with 3 additions and 0 deletions
--- a/api/rpc/client/conn.go
+++ b/api/rpc/client/conn.go
@ -10,6 +10,7 @@ import (
 type Conn interface {
 	grpc.ClientConnInterface
 	io.Closer
+	Connect()
 }

 // Conn returns underlying connection.
--- a/api/rpc/client/init.go
+++ b/api/rpc/client/init.go
@ -50,6 +50,8 @@ func (c *Client) Init(info common.CallMethodInfo, opts ...CallOption) (MessageRe
 		return nil, err
 	}

+	c.conn.Connect()
+
 	ctx, cancel := context.WithCancel(prm.ctx)
 	stream, err := c.conn.NewStream(ctx, &grpc.StreamDesc{
 		StreamName:    info.Name,