Method batch_recv

flow-rs/src/loader/python/channel.rs:47–67

(&self, py: Python, n: usize, dur: u64)

    }

    fn batch_recv(&self, py: Python, n: usize, dur: u64) -> (Vec<PyObject>, bool) {
        let convert = |envelope| {
            Py::new(
                py,
                PyEnvelope {
                    imp: Some(envelope),
                },
            )
            .unwrap()
            .to_object(py)
        };
        match with_context(py, || {
            wait(
                self.imp
                    .batch_recv::<PyObject>(n, Duration::from_millis(dur)),
            )
        }) {
            Ok(msg) => (msg.into_iter().map(convert).collect(), false),
            Err(BatchRecvError::Closed(msg)) => (msg.into_iter().map(convert).collect(), true),
        }
    }
}

pub trait Owned2PyObject {