Struct SingleThreadedEngine

pub struct SingleThreadedEngine { /* private fields */ }

Creates single threaded execution environment for Blocks to be run on.

Each block would be executed inside a local task in the engine’s local context.

Implementations

impl SingleThreadedEngine

pub fn new() -> Self

Construct

pub fn blocks(&self) -> Vec<&dyn BlockPropsType>

Get a list of all the blocks that are currently scheduled on this engine.

pub fn blocks_mut(&self) -> Vec<&mut dyn BlockPropsType>

Get a list of all the blocks that are currently scheduled on this engine.

Trait Implementations

impl Default for SingleThreadedEngine

fn default() -> Self

Returns the “default value” for a type.

impl Engine for SingleThreadedEngine

type Writer = Sender<Value>

The transmission type of the blocks

type Reader = Receiver<Value>

The reception type of the blocks

type Channel = Sender<EngineMessage<Sender<WatchMessage>>>

The type used to send messages to/from this engine.

fn schedule<B: Block<Writer = Self::Writer, Reader = Self::Reader> + 'static>( &mut self, block: B, )

Schedule a block to be executed by this engine. This operation can be performed while the engine is running.

fn load_blocks_and_links( &mut self, blocks: &[BlockData], links: &[LinkData], ) -> Result<()>

Load the blocks and links into the engine. This operation should be performed before the engine is run.

async fn run(&mut self)

Runs the event loop of this engine an execute the blocks that where scheduled

fn create_message_channel( &mut self, sender_id: Uuid, sender_channel: Self::Channel, ) -> Self::Channel

Get a handle to this engines messaging system so external systems can communicate with this engine once the engine will run.