-
-my $asapq = { queue => [], timer => undef };
-my $laterq = { queue => [], timer => undef };
-
-sub _run_all ($) {
- my ($q) = @_;
-
- my $run = $q->{queue};
- $q->{queue} = [];
- $q->{timer} = undef;
+require PublicInbox::DS;
+
+# this only runs under public-inbox-{httpd/nntpd}, not generic PSGI servers
+my $ENABLED;
+sub enabled { $ENABLED }
+sub enable { $ENABLED = 1 }
+my $laterq = [ [], undef ];
+
+sub _run_later () {
+ my $run = $laterq->[0];
+ $laterq->[0] = [];
+ $laterq->[1] = undef;