Struct AdapterRuntime 

pub struct AdapterRuntime { /* private fields */ }

Implementations

impl AdapterRuntime

pub async fn start( launch: LaunchSpec, request_timeout: Duration, ) -> Result<Self, AdapterError>

pub async fn post(&self, payload: Value) -> Result<PostOutcome, AdapterError>

pub async fn sse_stream( self: Arc<Self>, last_event_id: Option<u64>, ) -> impl Stream<Item = Result<Event, Infallible>> + Send + 'static

pub async fn value_stream( self: Arc<Self>, last_event_id: Option<u64>, ) -> impl Stream<Item = Value> + Send + 'static

Stream of raw JSON-RPC Value payloads (without SSE framing). Useful for consumers that need to inspect the payload contents rather than forward them as SSE events.

pub async fn shutdown(&self)

pub async fn stderr_tail_summary(&self) -> Option<String>

Trait Implementations

impl Debug for AdapterRuntime

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

Formats the value using the given formatter.