Struct protoflow_core::System

pub struct System<X: Transport + Default + 'static = MpscTransport> { /* private fields */ }

A system is a collection of blocks that are connected together.

Implementations

impl<X: Transport + Default + 'static> System<X>

pub fn build<F: FnOnce(&mut System<X>)>(f: F) -> Self

Builds a new system.

pub fn new(runtime: &Arc<StdRuntime<X>>) -> Self

Instantiates a new system.

pub fn execute(self) -> BlockResult<Rc<dyn Process>>

pub fn input<M: Message + 'static>(&self) -> InputPort<M>

pub fn output<M: Message + 'static>(&self) -> OutputPort<M>

pub fn block<B: Block + Clone + 'static>(&self, block: B) -> B

pub fn connect<M: Message>( &self, source: &OutputPort<M>, target: &InputPort<M>, ) -> bool

Trait Implementations

impl SystemBuilding for System

fn input<M: Message + 'static>(&self) -> InputPort<M>

Creates a new input port inside the system.

fn output<M: Message + 'static>(&self) -> OutputPort<M>

Creates a new output port inside the system.

fn block<B: Block + Clone + 'static>(&self, block: B) -> B

Instantiates a block inside the system.

fn connect<M: Message>( &self, source: &OutputPort<M>, target: &InputPort<M>, ) -> bool

Connects two ports of two blocks in the system.

impl SystemExecution for System

fn execute(self) -> BlockResult<Rc<dyn Process>>

Executes the system, returning the system process.