Struct RotaryProviderAdapter 

pub struct RotaryProviderAdapter { /* private fields */ }

Adapter that wraps an apollo Provider and implements rx4’s Provider trait. This lets rx4’s Agent loop use apollo’s existing provider backends (Anthropic, OpenAI-compat, Ollama, Copilot) without modification.

rx4’s Provider trait is streaming-based (stream()), while apollo’s is request-response (chat()). This adapter bridges the gap by calling apollo’s chat() and wrapping the result in a single-element stream.

Implementations

impl RotaryProviderAdapter

pub fn new(provider: Arc<dyn UnthinkclawProvider>) -> Self

Trait Implementations

impl Provider for RotaryProviderAdapter

fn id(&self) -> &str

fn name(&self) -> &str

fn stream<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>( &'life0 self, messages: &'life1 [Message], system: &'life2 Option<String>, model: &'life3 str, tools: &'life4 [Value], _reasoning_effort: Option<&'life5 str>, ) -> Pin<Box<dyn Future<Output = Result<StreamResult, Rx4ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait,

fn generate<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, messages: &'life1 [Message], system: &'life2 Option<String>, model: &'life3 str, tools: &'life4 [Value], ) -> Pin<Box<dyn Future<Output = Result<String, ProviderError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, Self: 'async_trait,

Non-streaming fallback (used when providers feature is off).