Function close_client

crates/pg/src/pg_server.rs:200–211

(client: &mut C, err: E)

}

async fn close_client<C, E>(client: &mut C, err: E) -> PgWireResult<()>
where
    C: ClientInfo + Sink<PgWireBackendMessage> + Unpin + Send,
    C::Error: Debug,
    PgWireError: From<<C as Sink<PgWireBackendMessage>>::Error>,
    pgwire::messages::response::ErrorResponse: From<E>,
{
    let err = pgwire::messages::response::ErrorResponse::from(err);
    client.feed(PgWireBackendMessage::ErrorResponse(err)).await?;
    client.close().await?;
    Ok(())
}

#[async_trait]
impl<T: Sync + Send + ControlStateReadAccess + ControlStateWriteAccess + NodeDelegate> StartupHandler