Struct ppl::pipeline::node::OutNode

pub struct OutNode<TOut, TCollected, TNext>
where
    TOut: Send,
    TNext: Node<TOut, TCollected>,
{ /* private fields */ }

Struct representing a Source node.

Implementations

impl<TOut, TCollected, TNext> OutNode<TOut, TCollected, TNext>

where TOut: Send + 'static, TNext: Node<TOut, TCollected> + Send + Sync + 'static,

pub fn new( handler: Box<dyn Out<TOut> + Send + Sync>, next_node: TNext, orchestrator: Arc<Orchestrator> ) -> OutNode<TOut, TCollected, TNext>

Create a new output Node.

The handler is the struct that implement the trait Out and defines the behavior of the node we’re creating. next_node contains the stage that follows the node.

pub fn start(&mut self)

Start the node. The node will start to send the output to the next node.

pub fn terminate(self)

Terminate the current node and the following ones. The node will terminate also when the stop flag is set to true.

Trait Implementations

impl<TIn, TOut, TCollected, TNext> Node<TIn, TCollected> for OutNode<TOut, TCollected, TNext>

where TIn: Send, TOut: Send + 'static, TNext: Node<TOut, TCollected> + Send + Sync + 'static,

fn send(&self, _input: Message<TIn>, _rec_id: usize) -> Result<(), SenderError>

Send a message to the node.

fn collect(self) -> Option<TCollected>

Collect the final result stored in the last stage of the pipeline where is located this node.

fn get_num_of_replicas(&self) -> usize

Fetch the number of replicas of this node.