diff --git a/rpc/client/connect.go b/rpc/client/connect.go index 18134c4..a5403e3 100644 --- a/rpc/client/connect.go +++ b/rpc/client/connect.go @@ -49,10 +49,16 @@ func (c *Client) openGRPCConn() error { dialCtx, cancel := context.WithTimeout(context.Background(), c.dialTimeout) var err error - c.conn, err = grpcstd.DialContext(dialCtx, c.addr, grpcstd.WithTransportCredentials(creds)) + c.conn, err = grpcstd.DialContext(dialCtx, c.addr, + grpcstd.WithTransportCredentials(creds), + grpcstd.WithBlock(), + ) cancel() + if err != nil { + return fmt.Errorf("open gRPC client connection: %w", err) + } - return err + return nil } // ParseURI parses s as address and returns a host and a flag