pub type TapWaker = Arc<dyn Fn() + Send + Sync>;
Wakes whoever drains the tap; called at most once per publish, after every tap lock is released.
pub struct TapWaker { /* private fields */ }