Struct System

pub struct System(/* private fields */);

Implementations

impl System

pub fn run<F: FnOnce(&mut System)>(f: F) -> BlockResult

Builds and executes a system, blocking until completion.

pub fn spawn<F: FnOnce(&mut System)>(f: F) -> BlockResult<Rc<dyn Process>>

Builds and executes a system, returning immediately.

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

Builds a new system.

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

Instantiates a new system.

Trait Implementations

impl CoreBlocks for System

fn buffer<T: Message + Into<T> + 'static>(&mut self) -> Buffer<T>

fn const_string(&mut self, value: impl ToString) -> Const<String>

fn count<T: Message + 'static>(&mut self) -> Count<T>

fn delay<T: Message + 'static>(&mut self) -> Delay<T>

fn delay_by<T: Message + 'static>(&mut self, delay: DelayType) -> Delay<T>

fn drop<T: Message + 'static>(&mut self) -> Drop<T>

fn random<T: Message + 'static>(&mut self) -> Random<T>

fn random_seeded<T: Message + 'static>( &mut self, seed: Option<u64>, ) -> Random<T>

fn delay_by_fixed<T: Message + 'static>(&mut self, delay: Duration) -> Delay<T>

fn delay_by_random<T: Message + 'static>( &mut self, delay: Range<Duration>, ) -> Delay<T>

impl Debug for System

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

Formats the value using the given formatter.

impl HashBlocks for System

fn hash_blake3(&mut self) -> Hash

impl IoBlocks for System

fn decode<T: Message + FromStr + 'static>(&mut self) -> Decode<T>

fn decode_json(&mut self) -> DecodeJson

fn decode_with<T: Message + FromStr + 'static>( &mut self, encoding: Encoding, ) -> Decode<T>

fn encode<T: Message + ToString + 'static>(&mut self) -> Encode<T>

fn encode_with<T: Message + ToString + 'static>( &mut self, encoding: Encoding, ) -> Encode<T>

fn encode_hex(&mut self) -> EncodeHex

fn encode_json(&mut self) -> EncodeJson

fn decode_lines<T: Message + FromStr + 'static>(&mut self) -> Decode<T>

fn encode_lines<T: Message + ToString + 'static>(&mut self) -> Encode<T>

impl SysBlocks for System

fn read_dir(&mut self) -> ReadDir

fn read_env(&mut self) -> ReadEnv

fn read_file(&mut self) -> ReadFile

fn read_stdin(&mut self) -> ReadStdin

fn write_file(&mut self) -> WriteFile

fn write_stderr(&mut self) -> WriteStderr

fn write_stdout(&mut self) -> WriteStdout

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>(&mut self, block: B) -> B

Instantiates a block inside the system.

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

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) -> BlockResult<Rc<dyn Process>>

Executes the system, returning the system process.

impl AllBlocks for System

impl FlowBlocks for System

impl MathBlocks for System

impl TextBlocks for System