Struct DevManagementConversation 

pub struct DevManagementConversation<S: ResumeStore> { /* private fields */ }

The node-side conversation: opened by the dev host, served by the adapter loop.

Implementations

impl<S: ResumeStore> DevManagementConversation<S>

pub fn open( attachment: &BusAttachment, store: S, ) -> Result<(Self, ConversationId), AttachError>

Opens the management conversation on the embedded bus, returning the id the handoff line advertises.

Errors

The typed attach failure.

pub fn join( attachment: &BusAttachment, conversation: ConversationId, store: S, ) -> Result<Self, AttachError>

Joins an advertised management conversation (the frame dev side).

Errors

The typed attach failure.

pub fn handle_mut(&mut self) -> &mut ConversationHandle<S>

The underlying handle, for the client side’s own request/subscribe calls (frame dev drives requests directly; only the NODE side runs the adapter serve loop).

Trait Implementations

impl<S: ResumeStore> ManagementConversation for DevManagementConversation<S>

fn next_request( &mut self, wait: Duration, ) -> Result<Option<InboundManagement>, String>

Waits up to wait for the next inbound request; Ok(None) is the benign quiet tick.

fn reply( &mut self, correlation: CorrelationId, reply: &DevReply, ) -> Result<(), String>

Publishes the exactly-one typed reply for correlation.

fn publish_status(&mut self, event: &DevStatusEvent) -> Result<(), String>

Publishes one S2 status event.