Struct Ctx

pub struct Ctx<G: Send + Sync> { /* private fields */ }

Provide a interface to send and recieve Package’s to/from others Component’s and access to read and modify the global data of the Flow.

Implementations

impl<G> Ctx<G>

where G: Send + Sync + 'static,

pub fn receive(&mut self, in_port: PortId) -> Option<Package>

Recieve a Package from a Port

Panics

Panic if recieve from a Input Port that not exist in this Component

pub fn send(&mut self, out_port: PortId, package: Package)

Send a Package to a Port, if one Component is connected to this port than he can recieve that Package sent.

If more than one components is connected in this port, each one recieve a copy of this Package.

Panics

Panic if send to a Output Port that not exist in this Component

pub fn with_global<R>(&self, call: impl FnOnce(&G) -> R) -> Result<R, FlowError>

Interface tha provide a way to read the global data of the Flow

pub fn with_mut_global<R>( &self, call: impl FnOnce(&mut G) -> R, ) -> Result<R, FlowError>

Interface tha provide a way to read and modify the global data of the Flow