No point in keeping a one-line wrapper sub around.
# ensure PublicInbox::DS::ToClose processing after timers fire
sub _asap_close () { $asapq->[1] ||= _asap_timer() }
-sub _run_asap () { _run_all($asapq) }
+# Called by PublicInbox::DS
+sub event_step { _run_all($asapq) }
+
sub _run_next () {
_run_all($nextq);
_asap_close();
_asap_close();
}
-# Called by PublicInbox::DS
-sub event_step {
- my ($self) = @_;
- _run_asap();
-}
-
sub _asap_timer () {
$singleton ||= once_init();
$singleton->watch(EPOLLOUT|EPOLLONESHOT);
}
END {
- _run_asap();
+ event_step();
_run_all($nextq);
_run_all($laterq);
}