pub fn close(&self) {
        if let Ok(mut core) = self.core.lock() {
            core.close()
        }
    }
/// Close down this [DataflowProgress] and fill any remaining waiters with an
/// error.
Close down this [DataflowProgress] and fill any remaining waiters with an
error.
Close down this [ DataflowProgress ] and fill any remaining waiters with an error .
pub fn close(&self) {
        if let Ok(mut core) = self.core.lock() {
            core.close()
        }
    }
pub fn close ( & self ) { if let Ok ( mut core ) = self . core . lock ( ) { core . close ( ) } }
Close down this [DataflowProgress] and fill any remaining waiters with an
error.
Close down this [ DataflowProgress ] and fill any remaining waiters with an error .
&self
&self