diff --git a/src/actix_web/inbox.rs b/src/actix_web/inbox.rs index a182c81..da90a7f 100644 --- a/src/actix_web/inbox.rs +++ b/src/actix_web/inbox.rs @@ -17,10 +17,10 @@ use tracing::debug; /// Handles incoming activities, verifying HTTP signatures and other checks /// /// After successful validation, activities are passed to respective [trait@ActivityHandler]. -pub async fn receive_activity( +pub async fn receive_activity( request: HttpRequest, body: Bytes, - hook: F, + hook: impl FnOnce(Activity, ActorT, Data) -> Fut, data: &Data, ) -> Result::Error> where @@ -30,7 +30,6 @@ where ::Error: From + From<::Error>, ::Error: From, Datatype: Clone, - F: FnOnce(Activity, ActorT, Data) -> Fut, Fut: Future::Error>>, { let digest_header = request @@ -84,7 +83,7 @@ mod test { #[tokio::test] async fn test_receive_activity_hook() { let (body, incoming_request, config) = setup_receive_test().await; - receive_activity::( + receive_activity::( incoming_request.to_http_request(), body, inbox_activity_hook,