Function handle_request 

async fn handle_request(
    peer_addr: SocketAddr,
    request_bytes: BytesMut,
    source: &mut Option<InputSourceHandle<InputMessage>>,
    global: &Global,
    priority_guard: &mut Option<PriorityGuard>,
) -> Result<(), FlatServerError>