diff --git a/api/rpc/client/connect.go b/api/rpc/client/connect.go index e22e0a6..57af64d 100644 --- a/api/rpc/client/connect.go +++ b/api/rpc/client/connect.go @@ -13,19 +13,17 @@ import ( var errInvalidEndpoint = errors.New("invalid endpoint options") func (c *Client) openGRPCConn(ctx context.Context, dialer func(ctx context.Context, cc grpcstd.ClientConnInterface) error) error { - if c.conn != nil { - return nil - } + if c.conn == nil { + if c.addr == "" { + return errInvalidEndpoint + } - if c.addr == "" { - return errInvalidEndpoint - } + var err error - var err error - - c.conn, err = grpcstd.NewClient(c.addr, c.grpcDialOpts...) - if err != nil { - return fmt.Errorf("gRPC new client: %w", err) + c.conn, err = grpcstd.NewClient(c.addr, c.grpcDialOpts...) + if err != nil { + return fmt.Errorf("gRPC new client: %w", err) + } } if dialer != nil {