Method new

src/pgtest/src/lib.rs:115–140

(
        addr: &str,
        user: &'a str,
        timeout: Duration,
        verbose: bool,
        mut options: Vec<(&'a str, &'a str)>,
    )

impl PgConn {
    fn new<'a>(
        addr: &str,
        user: &'a str,
        timeout: Duration,
        verbose: bool,
        mut options: Vec<(&'a str, &'a str)>,
    ) -> anyhow::Result<Self> {
        let mut conn = Self {
            stream: TcpStream::connect(addr)?,
            recv_buf: BytesMut::new(),
            send_buf: BytesMut::new(),
            timeout,
            verbose,
        };

        conn.stream.set_read_timeout(Some(timeout))?;
        options.insert(0, ("user", user));
        options.insert(0, ("welcome_message", "off"));
        conn.send(|buf| frontend::startup_message(options, buf).unwrap())?;
        match conn.recv()?.1 {
            Message::AuthenticationOk => {}
            _ => bail!("expected AuthenticationOk"),
        };
        conn.until(vec!["ReadyForQuery"], vec!['C', 'S', 'M'], BTreeSet::new())?;
        Ok(conn)
    }

    fn send<F: FnOnce(&mut BytesMut)>(&mut self, f: F) -> anyhow::Result<()> {
        self.send_buf.clear();