Struct puff_rs::python::PythonDispatcher

pub struct PythonDispatcher { /* private fields */ }

Implementations

impl PythonDispatcher

pub fn new(context_waiting: Arc<Mutex<Option<PuffContext>>>) -> PyResult<Self>

pub fn blocking() -> 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.

Trait Implementations

impl Clone for PythonDispatcher

fn clone(&self) -> PythonDispatcher

Returns a copy of the value.

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

Performs copy-assignment from source.