pub(super) fn connection( stream: TcpStream, queue: &SyncSender<Job>, state: &State, requests: &Arc<Registry>, sessions: &Arc<Mutex<Store>>, ) -> Result<()>