Skip to main content

run

Function run 

Source
pub async fn run(subscriber: Subscriber)
Expand description

Run until the process ends.

Never returns an error: a subscriber that gave up would leave messages queued with nothing to handle them, and the failure modes it could give up on — the database being briefly unreachable, a listener connection dropping — are all ones that fix themselves. Everything is logged and retried instead.