kabu_node_player::compose

Function replayer_compose_worker

Source 
pub(crate) async fn replayer_compose_worker(
    mempool: SharedState<Mempool>,
    compose_channel: Broadcaster<MessageTxCompose>,
) -> WorkerResult