1 files changed, 2 insertions, 5 deletions
diff --git a/lib/PublicInbox/LeiConvert.pm b/lib/PublicInbox/LeiConvert.pm
index 4a1f8323..9d2479b0 100644
--- a/lib/PublicInbox/LeiConvert.pm
+++ b/lib/PublicInbox/LeiConvert.pm
@@ -35,12 +35,9 @@ sub process_inputs { # via wq_do
          my $lei = $self->{lei};
          delete $lei->{1};
          my $l2m = delete $lei->{l2m};
-        my $nr_w = delete($l2m->{-nr_write}) // 0;
          delete $self->{wcb}; # commit
-        if (my $v2w = delete $lei->{v2w}) {
-                $nr_w = $v2w->wq_do('done'); # may die
-                $v2w->wq_close;
-        }
+        if (my $v2w = delete $lei->{v2w}) { $v2w->done } # may die
+        my $nr_w = delete($l2m->{-nr_write}) // 0;
          my $d = (delete($l2m->{-nr_seen}) // 0) - $nr_w;
          $d = $d ? " ($d duplicates)" : '';
          $lei->qerr("# converted $nr_w messages$d");