()
| 112 | } |
| 113 | |
| 114 | func (c *PgConn) rxSASLContinue() (*pgproto3.AuthenticationSASLContinue, error) { |
| 115 | msg, err := c.receiveMessage() |
| 116 | if err != nil { |
| 117 | return nil, err |
| 118 | } |
| 119 | switch m := msg.(type) { |
| 120 | case *pgproto3.AuthenticationSASLContinue: |
| 121 | return m, nil |
| 122 | case *pgproto3.ErrorResponse: |
| 123 | return nil, ErrorResponseToPgError(m) |
| 124 | } |
| 125 | |
| 126 | return nil, fmt.Errorf("expected AuthenticationSASLContinue message but received unexpected message %T", msg) |
| 127 | } |
| 128 | |
| 129 | func (c *PgConn) rxSASLFinal() (*pgproto3.AuthenticationSASLFinal, error) { |
| 130 | msg, err := c.receiveMessage() |
no test coverage detected