pub async fn collect_events(&mut self) -> Result<(), TMError> {
        if let Some(tm_event) = self.event_listener.get_event().await? {
            if let Ok(ibc_events) = relayer_modules::events::get_all_events(tm_event) {
                // TODO - send_timeout()?
                self.channel_to_handler
                    .send((self.chain_id, ibc_events))
                    .await?;
            }
        }
        Ok(())
    }
/// get a TM event and extract the IBC events
get a TM event and extract the IBC events
get a TM event and extract the IBC events
pub async fn collect_events(&mut self) -> Result<(), TMError> {
        if let Some(tm_event) = self.event_listener.get_event().await? {
            if let Ok(ibc_events) = relayer_modules::events::get_all_events(tm_event) {
                // TODO - send_timeout()?
                self.channel_to_handler
                    .send((self.chain_id, ibc_events))
                    .await?;
            }
        }
        Ok(())
    }
pub async fn collect_events ( & mut self ) -> Result < ( ) , TMError > { if let Some ( tm_event ) = self . event_listener . get_event ( ) . await ? { if let Ok ( ibc_events ) = relayer_modules :: events :: get_all_events ( tm_event ) { // TODO - send_timeout()? self . channel_to_handler . send ( ( self . chain_id , ibc_events ) ) . await ? ; } } Ok ( ( ) ) }
get a TM event and extract the IBC events
get a TM event and extract the IBC events
&mut self
&mut self