Implement new methods in multiindexer

INTEARnear · Dec 8, 2024 · ef45ba9 · ef45ba9
1 parent 66aefa1
commit ef45ba9
Showing 1 changed file with 18 additions and 0 deletions.
diff --git a/src/multiindexer.rs b/src/multiindexer.rs
@@ -122,6 +122,13 @@ impl<E: Debug + Send + Sync + 'static> Indexer for MultiIndexer<E> {
         Ok(())
     }
 
+    async fn process_block_end(&mut self, block: &StreamerMessage) -> Result<(), Self::Error> {
+        for indexer in self.indexers_mut() {
+            indexer.process_block_end(block).await?;
+        }
+        Ok(())
+    }
+
     async fn finalize(&mut self) -> Result<(), Self::Error> {
         for indexer in self.indexers_mut() {
             indexer.finalize().await?;
@@ -262,6 +269,17 @@ impl<
             .await
             .map_err(&self.map)
     }
+
+    async fn process_block_end(&mut self, block: &StreamerMessage) -> Result<(), Self::Error> {
+        self.indexer
+            .process_block_end(block)
+            .await
+            .map_err(&self.map)
+    }
+
+    async fn finalize(&mut self) -> Result<(), Self::Error> {
+        self.indexer.finalize().await.map_err(&self.map)
+    }
 }
 
 pub trait MapError {