Function chain_notifications_forwarder 

pub async fn chain_notifications_forwarder<P, Node, N>(
    executor: &TaskExecutor,
    provider: P,
    reth_provider: RpcBlockchainProvider<P, Node, N>,
) -> Result<()>
where
    P: RethApi + Send + Sync + 'static,
    Node: NodeTypes<Primitives = EthPrimitives>,
    N: Network,