Struct Collector 

pub struct Collector;

Installs itself on the bus and routes events to whichever request is running.

Implementations

impl Collector

pub fn install()

Subscribe once, for the life of the process.

Every dispatched event reaches this, and it drops the ones arriving on a task with no bar — a background job, a queue worker, anything that is not a request being rendered.

Idempotent, and it has to be. Subscribing twice does not collect twice as carefully; it records every query twice, and the bar then reports a page making double the queries it makes. A plugin registered in two places, or a test suite calling this per test, would both do it.

pub async fn collect<F, T>(work: F) -> (T, Collected)

where F: Future<Output = T>,

Run work with a collector installed, and return what it gathered.