lib/PublicInbox/LeiRemote.pm | 2 +- lib/PublicInbox/LeiXSearch.pm | 2 +- diff --git a/lib/PublicInbox/LeiRemote.pm b/lib/PublicInbox/LeiRemote.pm index 399fc9362c4792521b143bba5c3c64a1b0b3f45c..945d9990a535e7bb4a6c2b6d41ce40f99055b583 100644 --- a/lib/PublicInbox/LeiRemote.pm +++ b/lib/PublicInbox/LeiRemote.pm @@ -50,7 +50,7 @@ my $rdr = { 2 => $lei->{2}, pgid => 0 }; my ($fh, $pid) = popen_rd($cmd, undef, $rdr); my $reap = PublicInbox::OnDestroy->new($lei->can('sigint_reap'), $pid); $self->{smsg} = []; - $fh = IO::Uncompress::Gunzip->new($fh); + $fh = IO::Uncompress::Gunzip->new($fh, MultiStream => 1); PublicInbox::MboxReader->mboxrd($fh, \&_each_mboxrd_eml, $self); my $err = waitpid($pid, 0) == $pid ? undef : "BUG: waitpid($cmd): $!"; diff --git a/lib/PublicInbox/LeiXSearch.pm b/lib/PublicInbox/LeiXSearch.pm index 1a194f1c9dd9d45285e21bba796a0feb33095cc2..f3b8cc25f912c7571c65cb22c5fcb85d2345057c 100644 --- a/lib/PublicInbox/LeiXSearch.pm +++ b/lib/PublicInbox/LeiXSearch.pm @@ -272,7 +272,7 @@ my $cmd = $curl->for_uri($lei, $uri); $lei->qerr("# $cmd"); my ($fh, $pid) = popen_rd($cmd, undef, $rdr); $reap_curl = PublicInbox::OnDestroy->new($sigint_reap, $pid); - $fh = IO::Uncompress::Gunzip->new($fh); + $fh = IO::Uncompress::Gunzip->new($fh, MultiStream => 1); PublicInbox::MboxReader->mboxrd($fh, \&each_remote_eml, $self, $lei, $each_smsg); my $err = waitpid($pid, 0) == $pid ? undef