Struct KeelMiddleware 

pub struct KeelMiddleware { /* private fields */ }

A Middleware that wraps every request in the keel-core Engine chain. Owns a cloned reqwest::Client to send attempts itself (module docs explain why: Next/Extensions cannot cross into keel_core::Engine::execute’s effect closure under #[async_trait]’s Send-boxing requirement).

Add it as the last middleware (or the only one) so no transport-adjacent middleware after it is skipped:

keel::init()?;
let raw = reqwest::Client::new();
let client = reqwest_middleware::ClientBuilder::new(raw.clone())
    .with(keel::KeelMiddleware::new(raw))
    .build();
let resp = client.get("https://api.example.com/orders").send().await?;

Implementations

impl KeelMiddleware

pub fn new(client: Client) -> Self

client is the reqwest::Client used to actually send every attempt (cloning a reqwest::Client is cheap — it’s an Arc internally — so passing the same client you built the ClientWithMiddleware from is the normal usage).

Trait Implementations

impl Clone for KeelMiddleware

fn clone(&self) -> KeelMiddleware

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for KeelMiddleware

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

Formats the value using the given formatter.

impl Middleware for KeelMiddleware

fn handle<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, req: Request, _extensions: &'life1 mut Extensions, _next: Next<'life2>, ) -> Pin<Box<dyn Future<Output = MwResult<Response>> + Send + 'async_trait>>

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

Invoked with a request before sending it. If you want to continue processing the request, you should explicitly call next.run(req, extensions).