Struct RuntimeEndpoint 

pub struct RuntimeEndpoint { /* private fields */ }

Message-driven runtime endpoint.

Implements Endpoint<AgentEvent, RuntimeInput>. The run is started lazily when the first RuntimeInput::Run message arrives.

Implementations

impl RuntimeEndpoint

pub fn new(starter: RunStarter) -> Self

Create with a run factory that will be invoked on the first Run message.

pub fn with_buffer(starter: RunStarter, buffer: usize) -> Self

Create with a run factory and explicit event buffer size.

pub fn from_run_stream(run: RunStream) -> Self

Attach an already-started run (bypasses the Run message).

Useful for tests or contexts where the run was prepared externally.

pub fn from_run_stream_with_buffer(run: RunStream, buffer: usize) -> Self

Attach an already-started run with explicit buffer size.

Trait Implementations

impl Endpoint<AgentEvent, RuntimeInput> for RuntimeEndpoint

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

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

Transport-level close. Does not cancel the run.

fn recv<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<BoxStream<AgentEvent>, TransportError>> + Send + 'async_trait>>

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

fn send<'life0, 'async_trait>( &'life0 self, item: RuntimeInput, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

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