about summary refs log tree commit homepage
path: root/lib/PublicInbox/MailDiff.pm
diff options
context:
space:
mode:
authorEric Wong <e@80x24.org>2023-10-25 00:29:30 +0000
committerEric Wong <e@80x24.org>2023-10-25 07:28:34 +0000
commit82abcce5e42991db9bf8afb559a88708ff667697 (patch)
treee0805a16fc01bd2259337fef806c4d28cc295d8b /lib/PublicInbox/MailDiff.pm
parent947853b0b05f08c5678fb9d9c2e8521b7be9281a (diff)
downloadpublic-inbox-82abcce5e42991db9bf8afb559a88708ff667697.tar.gz
Callers that want to requeue can call PublicInbox::DS::requeue
directly and not go through the convoluted argument handling
via PublicInbox::HTTPD::Async->new.
Diffstat (limited to 'lib/PublicInbox/MailDiff.pm')
-rw-r--r--lib/PublicInbox/MailDiff.pm7
1 files changed, 3 insertions, 4 deletions
diff --git a/lib/PublicInbox/MailDiff.pm b/lib/PublicInbox/MailDiff.pm
index c3ce9365..908f223c 100644
--- a/lib/PublicInbox/MailDiff.pm
+++ b/lib/PublicInbox/MailDiff.pm
@@ -59,8 +59,7 @@ sub next_smsg ($) {
                 $ctx->write($ctx->_html_end);
                 return $ctx->close;
         }
-        my $async = $self->{ctx}->{env}->{'pi-httpd.async'};
-        $async->(undef, undef, $self) if $async # PublicInbox::HTTPD::Async->new
+        PublicInbox::DS::requeue($self) if $ctx->{env}->{'pi-httpd.async'};
 }
 
 sub emit_msg_diff {
@@ -125,8 +124,8 @@ sub event_step {
 
 sub begin_mail_diff {
         my ($self) = @_;
-        if (my $async = $self->{ctx}->{env}->{'pi-httpd.async'}) {
-                $async->(undef, undef, $self); # PublicInbox::HTTPD::Async->new
+        if ($self->{ctx}->{env}->{'pi-httpd.async'}) {
+                PublicInbox::DS::requeue($self);
         } else {
                 event_step($self) while $self->{smsg};
         }