def METHOD_NAME(self) -> None:
    assert self._stopped.is_set()
    for event_processor in self._event_processors.values():
        beamer.agent.metrics.init(
            config=self._config,
            source_rpc_url=event_processor.context.source_chain.rpc_url,
            target_rpc_url=event_processor.context.target_chain.rpc_url,
        )
        event_processor.METHOD_NAME()
    for event_monitor in self._event_monitors.values():
        event_monitor.METHOD_NAME()
    self._stopped.clear()