From c428a515bc44d70fcad688f9d2e8162fd1211194 Mon Sep 17 00:00:00 2001 From: Felix Ableitner Date: Mon, 4 Mar 2024 14:45:36 +0100 Subject: [PATCH] remove fn --- src/activity_sending.rs | 12 +++--------- 1 file changed, 3 insertions(+), 9 deletions(-) diff --git a/src/activity_sending.rs b/src/activity_sending.rs index ac38c25..f16ef37 100644 --- a/src/activity_sending.rs +++ b/src/activity_sending.rs @@ -113,14 +113,6 @@ impl SendActivityTask { } } -pub(crate) fn serialize_activity( - activity: &Activity, -) -> Result { - Ok(serde_json::to_vec(activity) - .map_err(|e| Error::SerializeOutgoingActivity(e, format!("{:?}", activity)))? - .into()) -} - pub(crate) async fn build_tasks<'a, Activity, Datatype, ActorType>( activity: &'a Activity, actor: &ActorType, @@ -135,7 +127,9 @@ where let config = &data.config; let actor_id = activity.actor(); let activity_id = activity.id(); - let activity_serialized = serialize_activity(activity)?; + let activity_serialized: Bytes = serde_json::to_vec(activity) + .map_err(|e| Error::SerializeOutgoingActivity(e, format!("{:?}", activity)))? + .into(); let private_key = get_pkey_cached(data, actor).await?; Ok(futures::stream::iter(