Method recv

flow-rs/src/loader/python/channel.rs:38–45

(&mut self, py: Python)

#[pymethods]
impl PyReceiver {
    fn recv(&mut self, py: Python) -> PyObject {
        match with_context(py, || wait(self.imp.recv::<PyObject>())) {
            Ok(msg) => Py::new(py, PyEnvelope { imp: Some(msg) })
                .unwrap()
                .to_object(py),
            _ => py.None(),
        }
    }

    fn batch_recv(&self, py: Python, n: usize, dur: u64) -> (Vec<PyObject>, bool) {
        let convert = |envelope| {