Struct System

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

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

Implementations

impl<X> System<X>

where X: Transport + Default + 'static,

pub fn build<F>(f: F) -> System<X>

where F: FnOnce(&mut System<X>),

Builds a new system.

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

Instantiates a new system.

pub fn execute(self) -> Result<Rc<dyn Process>, BlockError>

pub fn input<M>(&self) -> InputPort<M>

where M: Message + 'static,

pub fn output<M>(&self) -> OutputPort<M>

where M: Message + 'static,

pub fn block<B>(&mut self, block: B) -> B

where B: Block + Clone + 'static,

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

where M: Message,

Trait Implementations

impl Debug for System

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl SystemBuilding for System

fn input<M>(&self) -> InputPort<M>

where M: Message + 'static,

Creates a new input port inside the system.

fn output<M>(&self) -> OutputPort<M>

where M: Message + 'static,

Creates a new output port inside the system.

fn block<B>(&mut self, block: B) -> B

where B: Block + Clone + 'static,

Instantiates a block inside the system.

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

where M: Message,

Connects two ports of two blocks in the system.

fn input_any(&self) -> InputPort<Any>

fn input_bytes(&self) -> InputPort<Bytes>

fn input_string(&self) -> InputPort<String>

fn output_any(&self) -> OutputPort<Any>

fn output_bytes(&self) -> OutputPort<Bytes>

fn output_string(&self) -> OutputPort<String>

impl SystemExecution for System

fn execute(self) -> Result<Rc<dyn Process>, BlockError>

Executes the system, returning the system process.