about summary refs log tree commit homepage
path: root/lib/PublicInbox/LeiImportKw.pm
diff options
context:
space:
mode:
Diffstat (limited to 'lib/PublicInbox/LeiImportKw.pm')
-rw-r--r--lib/PublicInbox/LeiImportKw.pm8
1 files changed, 1 insertions, 7 deletions
diff --git a/lib/PublicInbox/LeiImportKw.pm b/lib/PublicInbox/LeiImportKw.pm
index 21c93515..c35c5c26 100644
--- a/lib/PublicInbox/LeiImportKw.pm
+++ b/lib/PublicInbox/LeiImportKw.pm
@@ -46,17 +46,11 @@ sub ck_update_kw { # via wq_io_do
         $self->{sto}->wq_do('set_eml_vmd', undef, { kw => $kw }, \@docids);
 }
 
-sub ikw_done_wait {
-        my ($arg, $pid) = @_;
-        my ($self, $lei) = @$arg;
-        $lei->can('wq_done_wait')->($arg, $pid);
-}
-
 sub _lei_wq_eof { # EOF callback for main lei daemon
         my ($lei) = @_;
         my $ikw = delete $lei->{ikw} or return $lei->fail;
         $lei->sto_done_request($ikw->{lei_sock});
-        $ikw->wq_wait_old(\&ikw_done_wait, $lei);
+        $ikw->wq_wait_old($lei->can('wq_done_wait'), $lei);
 }
 
 1;