Function handle_connection

atomic-cli/src/commands/agent/owner.rs:1313–1331

(
    mut stream: S,
    store: Arc<RedbChangeStore>,
    shutdown: Arc<Notify>,
)

}

async fn handle_connection<S>(
    mut stream: S,
    store: Arc<RedbChangeStore>,
    shutdown: Arc<Notify>,
) -> anyhow::Result<()>
where
    S: AsyncRead + AsyncWrite + Unpin,
{
    let request: RequestFrame = read_frame(&mut stream).await?;
    let (response, should_shutdown) = handle_request(&store, request);
    write_frame(&mut stream, &response).await?;
    stream.shutdown().await?;
    if should_shutdown {
        // `notify_one` retains a permit if the accept loop is between polls,
        // preventing a shutdown request from being acknowledged but lost.
        shutdown.notify_one();
    }
    Ok(())
}

async fn read_frame<T, S>(stream: &mut S) -> anyhow::Result<T>
where