wwwstream: eliminate ::response, use html_oneshot

[public-inbox.git] / lib / PublicInbox / SearchView.pm

diff --git a/lib/PublicInbox/SearchView.pm b/lib/PublicInbox/SearchView.pm
index eeebdfa3137903f64426b0fc96773a58b946a3bd..623b16fb22cd0d6282d01d001a16dd367531080e 100644 (file)
--- a/lib/PublicInbox/SearchView.pm
+++ b/lib/PublicInbox/SearchView.pm
@@ -287,21 +287,18 @@ sub mset_thread {
 
        @$msgs = reverse @$msgs if $r;
        $ctx->{msgs} = $msgs;
-       PublicInbox::WwwStream::response($ctx, 200, \&mset_thread_i);
+       PublicInbox::WwwStream::aresponse($ctx, 200, \&mset_thread_i);
 }
 
 # callback for PublicInbox::WwwStream::getline
 sub mset_thread_i {
-       my ($ctx) = @_;
-       return $ctx->html_top if exists $ctx->{-html_tip};
-       my $msgs = $ctx->{msgs} or return;
-       while (my $smsg = pop @$msgs) {
-               my $eml = $ctx->{-inbox}->smsg_eml($smsg) or next;
-               return PublicInbox::View::eml_entry($ctx, $smsg, $eml,
-                                                       scalar @$msgs);
-       }
-       my ($skel) = delete @$ctx{qw(skel msgs)};
-       $$skel .= "\n</pre>";
+       my ($ctx, $eml) = @_;
+       $ctx->zmore($ctx->html_top) if exists $ctx->{-html_tip};
+       $eml and return PublicInbox::View::eml_entry($ctx, $eml,
+                                               scalar @{$ctx->{msgs}});
+       my $smsg = shift @{$ctx->{msgs}} or
+               $ctx->zmore(${delete($ctx->{skel})});
+       $smsg;
 }
 
 sub ctx_prepare {