pub async fn run(
client_rx: UnboundedReceiver<Framed<UnixStream, FrameCodec>>,
metadata_slot: Arc<OnceLock<SessionMetadata>>,
) -> Result<()>pub async fn run(
client_rx: UnboundedReceiver<Framed<UnixStream, FrameCodec>>,
metadata_slot: Arc<OnceLock<SessionMetadata>>,
) -> Result<()>