kabu_strategy_merger::swappath_merger_actor

Function arb_swap_steps_optimizer_task

Source 
async fn arb_swap_steps_optimizer_task<DB: DatabaseRef<Error = KabuDBError> + Database<Error = KabuDBError> + DatabaseCommit + Send + Sync + Clone>(
    compose_channel_tx: Broadcaster<MessageSwapCompose<DB>>,
    _state_db: DB,
    header: Header,
    request: SwapComposeData<DB>,
) -> Result<()>