Method recv

src/response.rs:78–88

(&self, py: Python<'py>)

    }

    pub fn recv<'py>(&self, py: Python<'py>) -> PyResult<Bound<'py, PyAny>> {
        let inner = Arc::clone(&self.inner);

        future_into_py(py, async move {
            let resp = inner.lock().await.recv().await;

            resp.map(|r| convert_response(r?).context("convert response"))
                .transpose()
                .map_err(Into::into)
        })
    }
}

#[pyclass]