Enum ResponseCollector 

#[non_exhaustive]
pub enum ResponseCollector {
    Rows,
    Drain,
    Stream {
        header_tx: Sender<Result<StreamHeader, PgWireError>>,
        row_tx: Sender<Result<StreamedRow, PgWireError>>,
    },
    CopyIn {
        data: Vec<u8>,
    },
    CopyOut,
}

How to collect response messages for a request.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Rows

Collect DataRows until ReadyForQuery (for SELECT queries).

Drain

Just drain until ReadyForQuery (for setup commands like BEGIN, SET ROLE).

Stream

Stream rows one at a time via channels. Sends header first, then individual rows.

Fields

header_tx: Sender<Result<StreamHeader, PgWireError>>

One-shot channel for the row description (sent once before any rows).

row_tx: Sender<Result<StreamedRow, PgWireError>>

Bounded channel for individual rows; closed on completion or error.

CopyIn

COPY IN: after receiving CopyInResponse, send the provided data then CopyDone.

Fields

data: Vec<u8>

The data to send after CopyInResponse.

CopyOut

COPY OUT: collect CopyData messages until CopyDone.