()
| 2750 | } |
| 2751 | |
| 2752 | func (p *Pipeline) getResultsDeallocate() (*CloseComplete, error) { |
| 2753 | msg, err := p.receiveMessage() |
| 2754 | if err != nil { |
| 2755 | return nil, err |
| 2756 | } |
| 2757 | |
| 2758 | switch msg := msg.(type) { |
| 2759 | case *pgproto3.CloseComplete: |
| 2760 | return &CloseComplete{}, nil |
| 2761 | case *pgproto3.ErrorResponse: |
| 2762 | pgErr := ErrorResponseToPgError(msg) |
| 2763 | p.state.HandleError(pgErr) |
| 2764 | p.conn.resultReader.closed = true |
| 2765 | return nil, pgErr |
| 2766 | default: |
| 2767 | return nil, p.handleUnexpectedMessage("Deallocate", msg) |
| 2768 | } |
| 2769 | } |
| 2770 | |
| 2771 | func (p *Pipeline) getResultsSync() (*PipelineSync, error) { |
| 2772 | msg, err := p.receiveMessage() |
no test coverage detected