Struct MultiplexEngine 

pub struct MultiplexEngine { /* private fields */ }

Engine that dispatches prompts to multiple embacle runners concurrently

Implementations

impl MultiplexEngine

pub fn new(state: &SharedState) -> Self

Create a new multiplex engine backed by the shared server state

pub async fn execute( &self, messages: &[ChatMessage], providers: &[CliRunnerType], params: &MultiplexParams, ) -> Result<MultiplexResult, RunnerError>

Execute a prompt against all specified providers concurrently

Each provider runs in its own tokio task. Failures in one provider do not affect others — all results are collected and returned.