Struct puff_rs::python::PythonDispatcher

pub struct PythonDispatcher { /* private fields */ }

Implementations

impl PythonDispatcher

pub fn new(
    config: RuntimeConfig,
    context_waiting: Arc<Mutex<Option<PuffContext>>>,
    handle: Handle
) -> PyResult<Self>

pub fn dispatch_blocking<A: IntoPy<Py<PyTuple>>, K: IntoPy<Py<PyDict>>>(
    &self,
    py: Python<'_>,
    function: PyObject,
    args: A,
    kwargs: K
) -> PyResult<Receiver<PyResult<PyObject>>>

Run the python function a new Tokio blocking working thread.

pub fn dispatch1<A: IntoPy<Py<PyTuple>> + Send + 'static>(
    &self,
    function: PyObject,
    args: A
) -> PyResult<Receiver<PyResult<PyObject>>>

Acquires the GIL and Executes the python function on the greenlet thread or a new thread depending if greenlets were enabled. Takes no keyword arguments

pub fn dispatch<A: IntoPy<Py<PyTuple>>, K: IntoPy<Py<PyDict>>>(
    &self,
    function: PyObject,
    args: A,
    kwargs: Option<K>
) -> PyResult<Receiver<PyResult<PyObject>>>

Acquires the GIL and Executes the python function on the greenlet thread or a new thread depending if greenlets were enabled.

pub fn dispatch_greenlet<A: IntoPy<Py<PyTuple>>, K: IntoPy<Py<PyDict>>>(
    &self,
    py: Python<'_>,
    function: PyObject,
    args: A,
    kwargs: K
) -> PyResult<Receiver<PyResult<PyObject>>>

Executes the python function on the greenlet thread.

pub fn dispatch_asyncio<A: IntoPy<Py<PyTuple>>>(
    &self,
    function: PyObject,
    args: A,
    kwargs: Option<Py<PyDict>>
) -> PyResult<Receiver<PyResult<PyObject>>>

Executes the python function on the asyncio thread to create an awaitable to add.

pub fn dispatch_asyncio_coro(
    &self,
    py: Python<'_>,
    function: PyObject
) -> PyResult<Receiver<PyResult<PyObject>>>

Dispatch an awaitable coroutine onto the event loop.

Trait Implementations

impl Clone for PythonDispatcher

fn clone(&self) -> PythonDispatcher

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.