INNER CODE UNIT · Rust

running

jub0t/Concat · src/crates/concat-api/src/lib.rs:278

    pub fn running(&mut self) -> usize {
        self.jobs.reap();
        self.jobs.threads.len()
    }

    /// Waits for every running job to end. A transport calls this before
    /// it exits, so an export begun on its last line still finishes.
    pub fn finish(&mut self) {
        self.jobs.finish();
    }

    /// Runs one request. The response is what the request is worth; a job
    /// it begins reports through the sink from then on.
    pub fn dispatch(&mut self, request: Request) -> Response {
        self.jobs.reap();
        self.run(request).into()
    }

View source record →