Function drain_backlog 

pub async fn drain_backlog(emitter: &Emitter, deadline: Duration)

Waits until the emitter has nothing buffered, or deadline has passed.