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() }
# 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();
sub _run_next () {
_run_all($nextq);
_asap_close();
-# Called by PublicInbox::DS
-sub event_step {
- my ($self) = @_;
- _run_asap();
-}
-
sub _asap_timer () {
$singleton ||= once_init();
$singleton->watch(EPOLLOUT|EPOLLONESHOT);
sub _asap_timer () {
$singleton ||= once_init();
$singleton->watch(EPOLLOUT|EPOLLONESHOT);
_run_all($nextq);
_run_all($laterq);
}
_run_all($nextq);
_run_all($laterq);
}