Method wait_closed

src/pgwire/src/codec.rs:170–185

Waits for the connection to be closed. Returns a "connection closed" error when the connection is closed. If another error occurs before the connection is closed, that error is returned instead. Use this method when you have an unbounded stream of data to forward to the connection and the protocol does not require the client to periodically acknowledge receipt. If you don't call this method to p

(&self)

    /// not until the stream of data produces its next message and you attempt
    /// to write the data to the connection.
    pub async fn wait_closed(&self) -> io::Error
    where
        A: AsyncReady + Send + Sync,
    {
        loop {
            time::sleep(Duration::from_secs(1)).await;

            match self.ready(Interest::READABLE | Interest::WRITABLE).await {
                Ok(ready) if ready.is_read_closed() || ready.is_write_closed() => {
                    return io::Error::new(io::ErrorKind::Other, "connection closed");
                }
                Ok(_) => (),
                Err(err) => return err,
            }
        }
    }

    /// Returns the ID associated with this connection.
    pub fn conn_id(&self) -> &ConnectionId {