Function run

lambda-extension/src/lib.rs:33–41

Execute the given events processor

(events_processor: E)

/// Execute the given events processor
pub async fn run<E>(events_processor: E) -> Result<(), Error>
where
    E: Service<LambdaEvent>,
    E::Future: Future<Output = Result<(), E::Error>>,
    E::Error: Into<Box<dyn std::error::Error + Send + Sync>> + fmt::Display + fmt::Debug,
{
    let ext = Extension::new().with_events_processor(events_processor);
    ext.run().await
}