pub struct OperatorProcessor<'a, I, P, O> { /* private fields */ }Expand description
Operator Processor.
Implementations§
source§impl<'a, I, P, O> OperatorProcessor<'a, I, P, O>where
P: Operator<I, Output = O> + Send,
impl<'a, I, P, O> OperatorProcessor<'a, I, P, O>where P: Operator<I, Output = O> + Send,
sourcepub fn new(op: P) -> Self
pub fn new(op: P) -> Self
Create a new OperatorProcessor from the given operator.
Trait Implementations§
source§impl<'a, I, P, O> Publisher<'a> for OperatorProcessor<'a, I, P, O>where
P: Operator<I, Output = O>,
impl<'a, I, P, O> Publisher<'a> for OperatorProcessor<'a, I, P, O>where P: Operator<I, Output = O>,
source§fn subscribe<S>(&mut self, subscriber: S) -> Result<(), StreamError>where
S: Subscriber<Self::Output> + 'a,
fn subscribe<S>(&mut self, subscriber: S) -> Result<(), StreamError>where S: Subscriber<Self::Output> + 'a,
Subscribe.
source§impl<'a, I, P, O> Subscriber<I> for OperatorProcessor<'a, I, P, O>where
P: Operator<I, Output = O> + Send,
impl<'a, I, P, O> Subscriber<I> for OperatorProcessor<'a, I, P, O>where P: Operator<I, Output = O> + Send,
source§fn poll_ready(
self: Pin<&mut Self>,
cx: &mut Context<'_>
) -> Poll<Result<bool, StreamError>>
fn poll_ready( self: Pin<&mut Self>, cx: &mut Context<'_> ) -> Poll<Result<bool, StreamError>>
Poll ready.
source§fn start_send(self: Pin<&mut Self>, item: I) -> Result<(), StreamError>
fn start_send(self: Pin<&mut Self>, item: I) -> Result<(), StreamError>
Feed next item.
source§fn poll_flush(
self: Pin<&mut Self>,
cx: &mut Context<'_>
) -> Poll<Result<bool, StreamError>>
fn poll_flush( self: Pin<&mut Self>, cx: &mut Context<'_> ) -> Poll<Result<bool, StreamError>>
Poll flush.
source§fn closing(
self: Pin<&mut Self>,
reason: Result<(), StreamError>
) -> Result<(), StreamError>
fn closing( self: Pin<&mut Self>, reason: Result<(), StreamError> ) -> Result<(), StreamError>
Closing.
source§fn poll_close(
self: Pin<&mut Self>,
cx: &mut Context<'_>
) -> Poll<Result<(), StreamError>>
fn poll_close( self: Pin<&mut Self>, cx: &mut Context<'_> ) -> Poll<Result<(), StreamError>>
Poll close.
impl<'__pin, 'a, I, P, O> Unpin for OperatorProcessor<'a, I, P, O>where __Origin<'__pin, 'a, I, P, O>: Unpin,
Auto Trait Implementations§
impl<'a, I, P, O> !RefUnwindSafe for OperatorProcessor<'a, I, P, O>
impl<'a, I, P, O> Send for OperatorProcessor<'a, I, P, O>where P: Send,
impl<'a, I, P, O> !Sync for OperatorProcessor<'a, I, P, O>
impl<'a, I, P, O> !UnwindSafe for OperatorProcessor<'a, I, P, O>
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more