(errStr string)
| 2792 | } |
| 2793 | |
| 2794 | func (p *Pipeline) receiveParseComplete(errStr string) error { |
| 2795 | msg, err := p.receiveMessage() |
| 2796 | if err != nil { |
| 2797 | return err |
| 2798 | } |
| 2799 | |
| 2800 | switch msg := msg.(type) { |
| 2801 | case *pgproto3.ParseComplete: |
| 2802 | return nil |
| 2803 | case *pgproto3.ErrorResponse: |
| 2804 | pgErr := ErrorResponseToPgError(msg) |
| 2805 | p.state.HandleError(pgErr) |
| 2806 | return pgErr |
| 2807 | default: |
| 2808 | return p.handleUnexpectedMessage(fmt.Sprintf("%s Parse", errStr), msg) |
| 2809 | } |
| 2810 | } |
| 2811 | |
| 2812 | func (p *Pipeline) receiveBindComplete(errStr string) error { |
| 2813 | msg, err := p.receiveMessage() |
no test coverage detected