INNER CODE UNIT · Rust

listen

ekzhang/sshx · crates/sshx-server/src/lib.rs:70

    pub async fn listen<L>(&self, listener: L) -> Result<()>
    where
        L: Listener,
        L::Addr: Debug,
    {
        let state = self.state.clone();
        let terminated = self.shutdown.wait();
        tokio::spawn(async move {
            let background_tasks = futures_util::future::join(
                state.listen_for_transfers(),
                state.close_old_sessions(),
            );
            tokio::select! {
                _ = terminated => {}
                _ = background_tasks => {}
            }
        });

View source record →