fn try_report()

in src/channel.rs [68:76]

• 8 lines of code
• 2 McCabe index (conditional complexity)

    fn try_report(&self, item: CollectItem) -> anyhow::Result<()> {
        let stream = self
            .stream
            .get_or_try_init(|| UnixStream::connect(&self.worker_addr).map(Mutex::new))?
            .lock()
            .map_err(|_| anyhow!("Get Lock failed"))?;

        channel_send(item, stream)
    }