Struct SingleThreadedRuntime 

pub struct SingleThreadedRuntime {
    pub id: RuntimeID,
    /* private fields */
}

Single-threaded runtime implementation with internal event routing

Fields

id: RuntimeID

Implementations

impl SingleThreadedRuntime

pub fn new(channel_buffer: Option<usize>) -> Arc<Self>

pub fn with_transport( channel_buffer: Option<usize>, transport: Arc<dyn Transport>, ) -> Arc<Self>

Trait Implementations

impl Debug for SingleThreadedRuntime

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

Formats the value using the given formatter.

impl Runtime for SingleThreadedRuntime

fn id(&self) -> RuntimeID

fn subscribe_any<'life0, 'life1, 'async_trait>( &'life0 self, topic_name: &'life1 str, topic_type: TypeId, actor: Arc<dyn AnyActor>, ) -> Pin<Box<dyn Future<Output = Result<(), RuntimeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn publish_any<'life0, 'life1, 'async_trait>( &'life0 self, topic_name: &'life1 str, topic_type: TypeId, message: Arc<dyn Any + Send + Sync>, ) -> Pin<Box<dyn Future<Output = Result<(), RuntimeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn tx(&self) -> Sender<Event>

Local event processing sender. Agents receive this and emit protocol Events through it. The runtime is responsible for forwarding them to the owning Environment.

fn transport<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Arc<dyn Transport>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn take_event_receiver<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Option<BoxEventStream<Event>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn subscribe_events<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = BoxEventStream<Event>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Subscribe to runtime protocol events without consuming the receiver.

fn run<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Run the runtime event loop and process internal messages until stopped.

fn stop<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Request shutdown of the runtime.