]> Sergey Matveev's repositories - public-inbox.git/blobdiff - lib/PublicInbox/LeiRm.pm
lei: simplify common LeiInput users with ->wq1_start
[public-inbox.git] / lib / PublicInbox / LeiRm.pm
index cc1abbff66cb1e47a9fd0cd111d155059c10dffe..62423ac9828e7c2ec851f36de0161c08cd2fbaf3 100644 (file)
@@ -19,11 +19,8 @@ sub lei_rm {
        $lei->{opt}->{'in-format'} //= 'eml';
        my $self = bless {}, __PACKAGE__;
        $self->prepare_inputs($lei, \@inputs) or return;
-       my ($op_c, $ops) = $lei->workers_start($self, 1);
-       $lei->{wq1} = $self;
        $lei->{-err_type} = 'non-fatal';
-       net_merge_all_done($self) unless $lei->{auth};
-       $lei->wait_wq_events($op_c, $ops);
+       $lei->wq1_start($self);
 }
 
 no warnings 'once';