Skip to main content

apply_replay_message

hypercall::nats::replay_loop

Function apply_replay_message 

Source 
async fn apply_replay_message<H: ReplayHandler>(
    subscriber: &NatsReplaySubscriber,
    progress: &ReplayProgress,
    handler: &mut H,
    msg: ReplayMessage,
) -> Result<()>