fixes

graphprotocol · Sep 12, 2024 · b21706b · b21706b
1 parent 66e37ba
commit b21706b
Showing 1 changed file with 10 additions and 7 deletions.
diff --git a/graph/src/blockchain/block_stream.rs b/graph/src/blockchain/block_stream.rs
@@ -445,13 +445,16 @@ impl<C: Blockchain> TriggersAdapterWrapper<C> {
 
     fn create_subgraph_trigger_from_entity(
         filter: &SubgraphFilter,
-        entity: &Entity,
-    ) -> subgraph::TriggerData {
-        subgraph::TriggerData {
-            source: filter.subgraph.clone(),
-            entity: entity.clone(),
-            entity_type: filter.entities.first().unwrap().clone(),
-        }
+        entity: &Vec<Entity>,
+    ) -> Vec<subgraph::TriggerData> {
+        entity
+            .iter()
+            .map(|e| subgraph::TriggerData {
+                source: filter.subgraph.clone(),
+                entity: e.clone(),
+                entity_type: filter.entities.first().unwrap().clone(),
+            })
+            .collect()
     }
 }