pub struct Run<I, O, A> { /* private fields */ }Expand description
Run the Block computation by the specified input.
Trait Implementations§
Source§impl<I, O, A> Process for Run<I, O, A>where
A: Block<Input = I, Output = O> + 'static,
impl<I, O, A> Process for Run<I, O, A>where
A: Block<Input = I, Output = O> + 'static,
Source§fn and_then<U, F>(self, f: F) -> AndThen<Self, U, F>
fn and_then<U, F>(self, f: F) -> AndThen<Self, U, F>
Bind the current computation with its continuation within the resulting computation.
Source§fn map<B, F>(self, f: F) -> Map<Self, B, F>
fn map<B, F>(self, f: F) -> Map<Self, B, F>
Map the current computation using the specified transform.
Source§fn zip<U>(self, other: U) -> Zip<Self, U>
fn zip<U>(self, other: U) -> Zip<Self, U>
Zip the current computation with another one within the resulting computation.
Source§fn finally<U>(self, finalization: U) -> Finally<Self, U>
fn finally<U>(self, finalization: U) -> Finally<Self, U>
Finalize the current computation regardless of canceling it or not.
Source§fn run_using_id(self, pid: Grc<ProcessId>) -> Run<Self>
fn run_using_id(self, pid: Grc<ProcessId>) -> Run<Self>
Run the
Process computation using the specified process identifier.Source§fn into_boxed(self) -> ProcessBox<Self::Item>where
Self: Sized + 'static,
fn into_boxed(self) -> ProcessBox<Self::Item>where
Self: Sized + 'static,
Convert into a boxed value.
Auto Trait Implementations§
impl<I, O, A> Freeze for Run<I, O, A>
impl<I, O, A> RefUnwindSafe for Run<I, O, A>
impl<I, O, A> Send for Run<I, O, A>
impl<I, O, A> Sync for Run<I, O, A>
impl<I, O, A> Unpin for Run<I, O, A>
impl<I, O, A> UnsafeUnpin for Run<I, O, A>where
A: UnsafeUnpin,
I: UnsafeUnpin,
impl<I, O, A> UnwindSafe for Run<I, O, A>
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