Method clean

src/net/mod.rs:41–72

Frame-based eviction. Called once per frame from `eval()`.

(&mut self)

    /// Frame-based eviction. Called once per frame from `eval()`.
    pub fn clean(&mut self) {
        self.http_requests.retain(|_, entry| {
            // Try to receive if still pending
            if let HttpRequestState::Pending(pending) = &mut entry.state {
                if let Some(result) = pending.try_recv() {
                    match result {
                        Ok(resp) => {
                            entry.state =
                                HttpRequestState::Done(std::sync::Arc::new(resp));
                        }
                        Err(e) => {
                            entry.state = HttpRequestState::Error(e);
                        }
                    }
                }
            }

            match &entry.state {
                HttpRequestState::Pending(_) => true, // never evict
                _ => {
                    entry.frames_not_accessed += 1;
                    entry.frames_not_accessed <= self.max_frames_not_used
                }
            }
        });

        self.websockets.retain(|_, entry| {
            entry.frames_not_accessed += 1;
            let disconnected = entry.state.is_disconnected();
            !(disconnected && entry.frames_not_accessed > self.max_frames_not_used)
        });
    }
}

fn hash_id(id: &str) -> u64 {