From 4f904b7ac76a8f557e9597c330b0c077f62ebde4 Mon Sep 17 00:00:00 2001
From: Jeb Rosen <jeb@jebrosen.com>
Date: Mon, 25 May 2020 12:11:14 -0700
Subject: [PATCH] Work around a difficult lifetime interaction between closures
 and async blocks.

---
 plume-models/src/comments.rs | 17 ++++++++++-------
 1 file changed, 10 insertions(+), 7 deletions(-)

diff --git a/plume-models/src/comments.rs b/plume-models/src/comments.rs
index 03a01b2f..e03b9c0c 100644
--- a/plume-models/src/comments.rs
+++ b/plume-models/src/comments.rs
@@ -17,7 +17,6 @@ use activitypub::{
 };
 use chrono::{self, NaiveDateTime};
 use diesel::{self, ExpressionMethods, QueryDsl, RunQueryDsl, SaveChangesDsl};
-use futures::stream::{self, StreamExt};
 use plume_common::{
     activity_pub::{
         inbox::{AsActor, AsObject, FromId},
@@ -131,12 +130,16 @@ impl Comment {
             .set_published_string(chrono::Utc::now().to_rfc3339())?;
         note.object_props.set_attributed_to_link(author.into_id())?;
         note.object_props.set_to_link_vec(to)?;
-        note.object_props.set_tag_link_vec(
-            stream::iter(mentions)
-                .filter_map(|m| async move { Mention::build_activity(c, &m).await.ok() })
-                .collect::<Vec<link::Mention>>()
-                .await,
-        )?;
+
+        let mut tag_link_vec = vec![];
+        let mut iter = mentions.into_iter();
+        while let Some(m) = iter.next() {
+            if let Ok(a) = Mention::build_activity(c, &m).await {
+                tag_link_vec.push(a);
+            }
+        }
+        note.object_props.set_tag_link_vec(tag_link_vec)?;
+
         Ok(note)
     }