Trait pyo3_async::PyStream

pub trait PyStream: Send {
    // Required method
    fn poll_next_py(
        self: Pin<&mut Self>,
        py: Python<'_>,
        cx: &mut Context<'_>
    ) -> Poll<Option<PyResult<PyObject>>>;
}

GIL-bound [Stream].

Provided with a blanket implementation for [Stream]. GIL is maintained during polling operation. To release the GIL, see AllowThreads.

Required Methods

fn poll_next_py( self: Pin<&mut Self>, py: Python<'_>, cx: &mut Context<'_> ) -> Poll<Option<PyResult<PyObject>>>

GIL-bound [Stream::poll_next].

Implementors

impl<S, T, E> PyStream for Swhere S: Stream<Item = Result<T, E>> + Send, T: IntoPy<PyObject> + Send, E: Send, PyErr: From<E>,