pub struct InNode<TIn, TCollected>where
TIn: Send,{ /* private fields */ }
Expand description
Struct representing a Sink node.
Implementations§
source§impl<TIn, TCollected> InNode<TIn, TCollected>
impl<TIn, TCollected> InNode<TIn, TCollected>
sourcepub fn new(
handler: Box<dyn In<TIn, TCollected> + Send + Sync>,
orchestrator: Arc<Orchestrator>
) -> InNode<TIn, TCollected>
pub fn new( handler: Box<dyn In<TIn, TCollected> + Send + Sync>, orchestrator: Arc<Orchestrator> ) -> InNode<TIn, TCollected>
Create a new input Node.
The handler
is the struct that implement the trait In
and defines
the behavior of the node we’re creating.
next_node
contains the stage that follows the node.
Trait Implementations§
source§impl<TIn, TCollected> Node<TIn, TCollected> for InNode<TIn, TCollected>
impl<TIn, TCollected> Node<TIn, TCollected> for InNode<TIn, TCollected>
source§fn send(&self, input: Message<TIn>, rec_id: usize) -> Result<(), SenderError>
fn send(&self, input: Message<TIn>, rec_id: usize) -> Result<(), SenderError>
Send a message to the node.
source§fn collect(self) -> Option<TCollected>
fn collect(self) -> Option<TCollected>
Collect the final result stored in the last stage of the pipeline where is located this node.
source§fn get_num_of_replicas(&self) -> usize
fn get_num_of_replicas(&self) -> usize
Fetch the number of replicas of this node.
Auto Trait Implementations§
impl<TIn, TCollected> !RefUnwindSafe for InNode<TIn, TCollected>
impl<TIn, TCollected> Send for InNode<TIn, TCollected>where
TCollected: Send,
impl<TIn, TCollected> Sync for InNode<TIn, TCollected>where
TCollected: Send,
impl<TIn, TCollected> Unpin for InNode<TIn, TCollected>
impl<TIn, TCollected> !UnwindSafe for InNode<TIn, TCollected>
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