()
| 84 | } |
| 85 | |
| 86 | func (c *PgConn) rxGSSContinue() (*pgproto3.AuthenticationGSSContinue, error) { |
| 87 | msg, err := c.receiveMessage() |
| 88 | if err != nil { |
| 89 | return nil, err |
| 90 | } |
| 91 | |
| 92 | switch m := msg.(type) { |
| 93 | case *pgproto3.AuthenticationGSSContinue: |
| 94 | return m, nil |
| 95 | case *pgproto3.ErrorResponse: |
| 96 | return nil, ErrorResponseToPgError(m) |
| 97 | } |
| 98 | |
| 99 | return nil, fmt.Errorf("expected AuthenticationGSSContinue message but received unexpected message %T", msg) |
| 100 | } |
no test coverage detected