@@ -1055,15 +1055,18 @@ where
10551055 . stream
10561056 . stopwatch
10571057 . start_section ( PROCESS_WASM_BLOCK_SECTION_NAME ) ;
1058- self . handle_process_wasm_block (
1059- block_ptr,
1060- block_time,
1061- data,
1062- handler,
1063- cursor,
1064- cancel_handle,
1065- )
1066- . await ?
1058+ let res = self
1059+ . handle_process_wasm_block (
1060+ block_ptr. clone ( ) ,
1061+ block_time,
1062+ data,
1063+ handler,
1064+ cursor,
1065+ cancel_handle,
1066+ )
1067+ . await ;
1068+ let start = Instant :: now ( ) ;
1069+ self . handle_action ( start, block_ptr, res) . await ?
10671070 }
10681071 Some ( Ok ( BlockStreamEvent :: ProcessBlock ( block, cursor) ) ) => {
10691072 let _section = self
@@ -1221,7 +1224,7 @@ trait StreamEventHandler<C: Blockchain> {
12211224 handler : String ,
12221225 cursor : FirehoseCursor ,
12231226 cancel_handle : & CancelHandle ,
1224- ) -> Result < Action , Error > ;
1227+ ) -> Result < Action , BlockProcessingError > ;
12251228 async fn handle_process_block (
12261229 & mut self ,
12271230 block : BlockWithTriggers < C > ,
@@ -1255,7 +1258,7 @@ where
12551258 handler : String ,
12561259 cursor : FirehoseCursor ,
12571260 cancel_handle : & CancelHandle ,
1258- ) -> Result < Action , Error > {
1261+ ) -> Result < Action , BlockProcessingError > {
12591262 let logger = self . logger . new ( o ! (
12601263 "block_number" => format!( "{:?}" , block_ptr. number) ,
12611264 "block_hash" => format!( "{}" , block_ptr. hash)
0 commit comments