Function pyo3_asyncio::generic::into_coroutine[][src]

pub fn into_coroutine<R, F>(py: Python<'_>, fut: F) -> PyResult<PyObject> where
    R: Runtime,
    F: Future<Output = PyResult<PyObject>> + Send + 'static, 

Convert a Rust Future into a Python coroutine with a generic runtime

Arguments

  • py - The current PyO3 GIL guard
  • fut - The Rust future to be converted

Examples

use std::time::Duration;

use pyo3::prelude::*;

/// Awaitable sleep function
#[pyfunction]
fn sleep_for(py: Python, secs: &PyAny) -> PyResult<PyObject> {
    let secs = secs.extract()?;

    pyo3_asyncio::generic::into_coroutine::<MyCustomRuntime, _>(py, async move {
        MyCustomRuntime::sleep(Duration::from_secs(secs)).await;
        Python::with_gil(|py| Ok(py.None()))
   })
}