Struct HttpAgent

pub struct HttpAgent { /* private fields */ }

Implementations

impl HttpAgent

pub fn new(base_url: Url, header_map: HeaderMap) -> Self

pub fn builder() -> HttpAgentBuilder

Trait Implementations

impl<StateT: AgentState, FwdPropsT: FwdProps> Agent<StateT, FwdPropsT> for HttpAgent

fn run<'life0, 'life1, 'async_trait>( &'life0 self, input: &'life1 RunAgentInput<StateT, FwdPropsT>, ) -> Pin<Box<dyn Future<Output = Result<BoxStream<'async_trait, Result<Event<StateT>, AgentError>>, AgentError>> + Send + 'async_trait>>

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

fn run_agent<'life0, 'life1, 'async_trait>( &'life0 self, params: &'life1 RunAgentParams<StateT, FwdPropsT>, subscribers: impl 'async_trait + IntoSubscribers<StateT, FwdPropsT>, ) -> Pin<Box<dyn Future<Output = Result<RunAgentResult<StateT>, AgentError>> + Send + 'async_trait>>

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

The main execution method, containing the full pipeline logic.