Method is_closed

flow-rs/src/node/port.rs:186–195

(&self)

    }

    pub fn is_closed(&self) -> bool {
        let mut is_closed = self
            .brokers
            .values()
            .fold(false, |is_closed, broker| is_closed && broker.is_closed());
        for chan in self.cache.values() {
            is_closed = is_closed && chan.is_closed();
        }
        is_closed
    }
}

impl DynPorts<Sender> {